Anoma.Client.GRPC.PubSub (Anoma v0.34.0)
I handle all incoming request for the PubSub endpoint of the client.
Summary
Functions
@spec publish(Anoma.Proto.PubSub.Event.Request.t(), GRPC.Server.Stream.t()) :: Anoma.Proto.PubSub.Event.Response.t()
I handle incoming events sent t`o me by a node.