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
Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Lets keep this one for now.

Copy link
Copy Markdown
Author

@shubhamdhama shubhamdhama Apr 14, 2026

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Any reason for this? Otherwise it would be just a dead-code.


// 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