bidi<I extends Object, O extends Object> method

FakeTransportBuilder bidi<I extends Object, O extends Object>(
  1. Spec<I, O> spec,
  2. Stream<O> handler(
    1. Stream<I> request,
    2. FakeHandlerContext context
    )
)

Register a bidi streaming handler.

Implementation

FakeTransportBuilder bidi<I extends Object, O extends Object>(
  Spec<I, O> spec,
  Stream<O> Function(
    Stream<I> request,
    FakeHandlerContext context,
  ) handler,
) {
  _assertSpecStream(spec, StreamType.bidi);
  _handlers[spec] = handler;
  return this;
}