Skip to content

Commit d9ec023

Browse files
committed
query: Removed unused QueueMessageWithEncoding from Peer interface.
Signed-off-by: Maureen Ononiwu <[email protected]>
1 parent 4dbe2e8 commit d9ec023

File tree

2 files changed

+0
-11
lines changed

2 files changed

+0
-11
lines changed

query/interface.go

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -176,11 +176,6 @@ type Dispatcher interface {
176176
// Peer is the interface that defines the methods needed by the query package
177177
// to be able to make requests and receive responses from a network peer.
178178
type Peer interface {
179-
// QueueMessageWithEncoding adds the passed bitcoin message to the peer
180-
// send queue.
181-
QueueMessageWithEncoding(msg wire.Message, doneChan chan<- struct{},
182-
encoding wire.MessageEncoding)
183-
184179
// SubscribeRecvMsg adds a OnRead subscription to the peer. All bitcoin
185180
// messages received from this peer will be sent on the returned
186181
// channel. A closure is also returned, that should be called to cancel

query/worker_test.go

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -48,12 +48,6 @@ type mockPeer struct {
4848

4949
var _ Peer = (*mockPeer)(nil)
5050

51-
func (m *mockPeer) QueueMessageWithEncoding(msg wire.Message,
52-
doneChan chan<- struct{}, encoding wire.MessageEncoding) {
53-
54-
m.requests <- msg
55-
}
56-
5751
func (m *mockPeer) SubscribeRecvMsg() (<-chan wire.Message, func()) {
5852
msgChan := make(chan wire.Message)
5953
m.subscriptions <- msgChan

0 commit comments

Comments
 (0)