stream

Documentation

Index

• type Stream
  • func NewStream[T any](ctx context.Context, st *connect.ServerStream[T]) *Stream[T]
  • func (s *Stream[T]) Close()
  • func (s *Stream[T]) Run() error
  • func (s *Stream[T]) Send(data *T)
• type StreamInterface

Types

type Stream

type Stream[T any] struct {
	// contains filtered or unexported fields
}

Stream wraps a connect.ServerStream.

func NewStream

func NewStream[T any](ctx context.Context, st *connect.ServerStream[T]) *Stream[T]

newStream creates a new stream.

func (*Stream[T]) Close

func (s *Stream[T]) Close()

Close closes the stream.

func (*Stream[T]) Run

func (s *Stream[T]) Run() error

Run runs the stream. Run will block until the stream is closed.

func (*Stream[T]) Send

func (s *Stream[T]) Send(data *T)

Send sends data to this stream's connected client.

type StreamInterface

type StreamInterface[T any] interface {
	Send(data *T)
	Run() error
	Close()
}