Documentation

Overview

    Package stream encapsulates streams within streams

    Index

    Constants

    This section is empty.

    Variables

    This section is empty.

    Functions

    func New

    func New(service, endpoint string, req interface{}, s Stream) server.Stream

      New returns a new encapsulated stream Proto stream within a server.Stream

      Types

      type Stream

      type Stream interface {
      	Context() context.Context
      	SendMsg(interface{}) error
      	RecvMsg(interface{}) error
      	Close() error
      }

      Source Files