Anoma.Node.Transport.GRPC.Servers.PubSub (Anoma v0.34.0)

Summary

Functions

publish(request, stream)
service_name(_)
subscribe(request, stream)
unsubscribe(request, stream)

Functions

publish(request, stream)

service_name(_)

subscribe(request, stream)

@spec subscribe(Anoma.Proto.PubSub.Subscribe.Request.t(), GRPC.Server.Stream.t()) ::
  Anoma.Proto.PubSub.Subscribe.Response.t()

unsubscribe(request, stream)

@spec unsubscribe(Anoma.Proto.PubSub.Unsubscribe.Request.t(), GRPC.Server.Stream.t()) ::
  Anoma.Proto.PubSub.Unsubscribe.Response.t()