type streamProtocolV1 … var _ … func newStreamProtocolV1(options StreamOptions) streamProtocolHandler { … } func (p *streamProtocolV1) stream(conn streamCreator) error { … }
type streamProtocolV1 … var _ … func newStreamProtocolV1(options StreamOptions) streamProtocolHandler { … } func (p *streamProtocolV1) stream(conn streamCreator) error { … }