Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

stream

package

Go to main page

Versions in this module

v0

v0.0.7

May 27, 2026

Changes in this version

+ type BidiStreaming interface

+ Context func() context.Context

+ Recv func() (*Req, error)

+ Send func(*Res) error

v0.0.6

May 27, 2026

v0.0.5

May 11, 2026

Changes in this version

+ type ClientServerStreamingClient struct

+ func NewClientServerStreamingClient[Res any](stream grpc.ServerStreamingClient[Res], reqCallback ReqCallback[Res], ...) *ClientServerStreamingClient[Res]

+ func (client *ClientServerStreamingClient[Res]) Process(ctx context.Context) error

+ type ClientServerStreamingServer struct

+ func NewClientServerStreamingServer[Res any](stream grpc.ServerStreamingServer[Res], bufferSize uint32) *ClientServerStreamingServer[Res]

+ func (client *ClientServerStreamingServer[Res]) Process(ctx context.Context) error

+ func (client *ClientServerStreamingServer[Res]) Send(message *Res) error

v0.0.4

May 11, 2026

Changes in this version

+ type ClientBidiStreamingServer struct

+ func NewClientBidiStreamingServer[Req any, Res any](stream grpc.BidiStreamingServer[Req, Res], reqCallback ReqCallback[Req], ...) *ClientBidiStreamingServer[Req, Res]

+ func (client *ClientBidiStreamingServer[Req, Res]) Process(ctx context.Context) error

+ func (client *ClientBidiStreamingServer[Req, Res]) Send(message *Res) error

+ type ClientServerStreaming struct

+ func NewClientServerStreaming[Res any](grpcClient grpc.ServerStreamingServer[Res], bufferSize uint32) *ClientServerStreaming[Res]

+ func (client *ClientServerStreaming[Res]) Process(ctx context.Context) error

+ func (client *ClientServerStreaming[Res]) Send(message *Res) error

+ type ReqCallback func(ctx context.Context, req *Req) error

v0.0.3

Apr 18, 2026

Changes in this version

+ var MessageChanClosedError = errors.New("message channel is closed")

+ var MessageChanFullError = errors.New("message channel is full")

+ var SendMessageError = errors.New("send message error")

+ type Client struct

+ func NewClient[T any](grpcClient grpc.ServerStreamingServer[T], bufferSize uint32) *Client[T]

+ func (client *Client[T]) Process(ctx context.Context) error

+ func (client *Client[T]) Send(message *T) error