6
0
Derivar 0

Fix final test

Este cometimento está contido em:
James Mills 2022-04-03 19:00:53 +10:00
ascendente 9b9800a001
cometimento 847f823999
Não foi encontrada uma chave conhecida para esta assinatura, na base de dados
ID da chave GPG: AC4C014F1440EBD6

Ver ficheiro

@ -30,15 +30,12 @@ func TestClientPublish(t *testing.T) {
client := NewClient(server.URL, nil)
err = client.Publish("hello", "hello world")
assert.NoError(err)
topic := mb.NewTopic("hello")
expected := msgbus.Message{Topic: topic, Payload: []byte("hello world")}
actual, ok := mb.Get(topic)
msg, ok := mb.Get(topic)
require.True(ok)
assert.Equal(expected.ID, actual.ID)
assert.Equal(expected.Topic, actual.Topic)
assert.Equal(expected.Payload, actual.Payload)
assert.Equal(int64(1), msg.ID)
assert.Equal(topic, msg.Topic)
assert.Equal([]byte("hello world"), msg.Payload)
}