Anoma.Client.GRPC.PubSub (Anoma v0.34.0)

I handle all incoming request for the PubSub endpoint of the client.

Summary

Functions

publish(request, stream)

I handle incoming events sent t`o me by a node.

service_name(_)

Functions

publish(request, stream)

@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.

service_name(_)