Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 0 additions & 8 deletions drpc.go
Original file line number Diff line number Diff line change
Expand Up @@ -76,14 +76,6 @@ type Stream interface {
// received on it.
Context() context.Context

// Kind returns the type of the stream ("unknown", "cli", or "srv"). Client
// and server streams must be treated differently for error handling and
// logging purposes.
//
// Client streams return Unavailable errors when the remote closes the
// connection, while server streams return Canceled errors.
Kind() StreamKind

// MsgSend sends the Message to the remote.
MsgSend(msg Message, enc Encoding) error

Expand Down
74 changes: 0 additions & 74 deletions drpccache/README.md

This file was deleted.

92 changes: 0 additions & 92 deletions drpccache/cache.go

This file was deleted.

71 changes: 0 additions & 71 deletions drpccache/cache_test.go

This file was deleted.

5 changes: 0 additions & 5 deletions drpccache/doc.go

This file was deleted.

1 change: 0 additions & 1 deletion drpcclient/dialoptions.go
Original file line number Diff line number Diff line change
Expand Up @@ -129,7 +129,6 @@ func DialContext(ctx context.Context, address string, opts ...DialOption) (conn
Stream: drpcstream.Options{
MaximumBufferSize: 0, // unlimited
},
SoftCancel: false,
},
}), nil
}
Loading