diff --git a/hashmail_server.go b/hashmail_server.go index dec6f64..b4ac76f 100644 --- a/hashmail_server.go +++ b/hashmail_server.go @@ -317,7 +317,7 @@ type hashMailServerConfig struct { // write pipes. type hashMailServer struct { hashmailrpc.UnimplementedHashMailServer - + sync.RWMutex streams map[streamID]*stream diff --git a/hashmail_server_test.go b/hashmail_server_test.go index 60b9116..fd2ee21 100644 --- a/hashmail_server_test.go +++ b/hashmail_server_test.go @@ -119,13 +119,13 @@ func TestHashMailServerLargeMessage(t *testing.T) { require.NotNil(t, resp.GetSuccess()) // Let's create a long message and try to send it. - var largeMessage [512*DefaultBufSize]byte + var largeMessage [512 * DefaultBufSize]byte _, err = rand.Read(largeMessage[:]) require.NoError(t, err) - + sendCtx, sendCancel := context.WithCancel(context.Background()) defer sendCancel() - + writeStream, err := client.SendStream(sendCtx) require.NoError(t, err) err = writeStream.Send(&hashmailrpc.CipherBox{