deepsource

beacon-chain/blockchain/testing/mock.go

@@ -117,7 +117,7 @@ func (w *EventFeedWrapper) Send(value interface{}) int {
 	return w.feed.Send(value)
 }
 
-// WAitForSubscription allows test to wait for the feed to have a subscription before beginning to send events.
+// WaitForSubscription allows test to wait for the feed to have a subscription before beginning to send events.
 func (w *EventFeedWrapper) WaitForSubscription(ctx context.Context) error {
 	select {
 	case <-w.subscribed:

beacon-chain/rpc/eth/events/events_test.go

@@ -29,21 +29,6 @@ import (
 	sse "github.com/r3labs/sse/v2"
 )
 
-type flushableResponseRecorder struct {
-	*httptest.ResponseRecorder
-	flushed bool
-}
-
-func (f *flushableResponseRecorder) Flush() {
-	f.flushed = true
-}
-
-func NewFlushabaleResponseRecorder() *flushableResponseRecorder {
-	return &flushableResponseRecorder{
-		ResponseRecorder: httptest.NewRecorder(),
-	}
-}
-
 func requireAllEventsReceived(t *testing.T, stn, opn *mockChain.EventFeedWrapper, events []*feed.Event, req *topicRequest, s *Server, w *StreamingResponseWriterRecorder) {
 	// maxBufferSize param copied from sse lib client code
 	sseR := sse.NewEventStreamReader(w.Body(), 1<<24)