14 lines
210 B
Go
14 lines
210 B
Go
package v1
|
|
|
|
import (
|
|
"google.golang.org/protobuf/proto"
|
|
)
|
|
|
|
type StreamSender[T proto.Message] interface {
|
|
Send(msg T) error
|
|
}
|
|
|
|
type StreamReceiver[T proto.Message] interface {
|
|
Receive() (msg T, err error)
|
|
}
|