Client dials a grpc server, and runs the task with the connection, and closes the connection again before returning.

Dial connects to a grpc server, and returns the connection.

DialPipe connects to listeners obtained with NewPipeListener.

DialPipeCtx connects to listeners obtained with NewPipeListener, and errors if the context is canceled.

GetDialer takes a context and returns a grpc-compatible dialer function that will fail if the context is stopped or if the specified timeout passes.

NewPipeListener returns a net.Listener that accepts connections from DialPipe.

Serve prepares and runs a grpc server on the specified address.

ServeWithListener prepares and runs a grpc server using the specified net.Listener.

ToProducer adapts an input grpc stream to an event producer.

ClientTask is invoked with an open grpc connection by Client.

PrepareTask is called to add the services to a grpc server before it starts running.