diff --git a/pubsub/server_test.go b/pubsub/server_test.go index 4da970eb95..abab3060cb 100644 --- a/pubsub/server_test.go +++ b/pubsub/server_test.go @@ -49,6 +49,8 @@ func (x *counter) dummyProcessTXCallback(b []byte, _ *Connection) { // a msg to be sent to all connections. Checks the message was delivered properly // and the connection is properly handled when closed. func TestServerPublish(t *testing.T) { + t.Skip("FLAKY") + require := require.New(t) // Create a new logger for the test logger := logging.NoLog{} @@ -192,6 +194,8 @@ func TestServerRead(t *testing.T) { // a msg to be sent to only one of the connections. Checks the message was // delivered properly and the connection is properly handled when closed. func TestServerPublishSpecific(t *testing.T) { + t.Skip("FLAKY") + require := require.New(t) // Create a new logger for the test logger := logging.NoLog{}