server<I extends Object, O extends Object> method

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

Register a server streaming handler.

Implementation

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