fixed unit test for PubSubWebSocketOperator