diff --git a/restlike/connect/receiver_test.go b/restlike/connect/receiver_test.go index d64f0cadc6b92159e212bba0409c8027c1984c5b..723ec019fbedf4532b4f2a3d2bf3f66be51d36b1 100644 --- a/restlike/connect/receiver_test.go +++ b/restlike/connect/receiver_test.go @@ -19,41 +19,3 @@ func TestSingleReceiver_Callback_FailUnmarshal(t *testing.T) { r.Hear(receive.Message{Payload: []byte("test")}) } - -// Test happy path -//func TestSingleReceiver_Callback(t *testing.T) { -// ep := &Endpoints{endpoints: make(map[URI]map[Method]Callback)} -// resultChan := make(chan interface{}, 1) -// cb := func(*Message) *Message { -// resultChan <- "" -// return nil -// } -// testPath := URI("test/path") -// testMethod := Get -// testMessage := &Message{ -// Content: []byte("test"), -// Headers: nil, -// Method: uint32(testMethod), -// Uri: string(testPath), -// Error: "", -// } -// -// err := ep.Add(testPath, testMethod, cb) -// if err != nil { -// t.Errorf(err.Error()) -// } -// receiver := singleReceiver{endpoints: ep} -// -// testPayload, err := proto.Marshal(testMessage) -// if err != nil { -// t.Errorf(err.Error()) -// } -// testReq := single.BuildTestRequest(testPayload, t) -// receiver.Callback(testReq, receptionID.EphemeralIdentity{}, nil) -// -// select { -// case _ = <-resultChan: -// case <-time.After(3 * time.Second): -// t.Errorf("Test SingleReceiver timed out!") -// } -//}