Function expectMessage

api/stream/stream_test.go:570–574

(expected *model.MessageExternal, clients ...*testingClient)

}

func expectMessage(expected *model.MessageExternal, clients ...*testingClient) {
	for _, client := range clients {
		client.expectMessage(expected)
	}
}

func expectNoMessage(clients ...*testingClient) {
	for _, client := range clients {