streamingservice

Documentation

Index

• type StreamingService
  • func NewStreamingService() *StreamingService
  • func (s *StreamingService) BiDirectionalStream(ctx context.Context, ...) error
  • func (s *StreamingService) ClientStream(ctx context.Context, stream *connect_go.ClientStream[sample.GreetRequest]) (*connect_go.Response[sample.GreetResponse], error)
  • func (s *StreamingService) ResponseStream(ctx context.Context, req *connect_go.Request[sample.GreetRequest], ...) error

Types

type StreamingService

type StreamingService struct {
	sampleconnect.UnimplementedStreamingServiceHandler
}

StreamingService implements tutorial.StreamingService.

func NewStreamingService

func NewStreamingService() *StreamingService

func (*StreamingService) BiDirectionalStream

func (s *StreamingService) BiDirectionalStream(ctx context.Context, stream *connect_go.BidiStream[sample.GreetRequest, sample.GreetResponse]) error

BiDirectionalStream implements tutorial.StreamingService.BiDirectionalStream.

func (*StreamingService) ClientStream

func (s *StreamingService) ClientStream(ctx context.Context, stream *connect_go.ClientStream[sample.GreetRequest]) (*connect_go.Response[sample.GreetResponse], error)

ClientStream implements tutorial.StreamingService.ClientStream.

func (*StreamingService) ResponseStream

func (s *StreamingService) ResponseStream(ctx context.Context, req *connect_go.Request[sample.GreetRequest], stream *connect_go.ServerStream[sample.GreetResponse]) error

ResponseStream implements tutorial.StreamingService.ResponseStream.