File tree Expand file tree Collapse file tree 1 file changed +0
-27
lines changed Expand file tree Collapse file tree 1 file changed +0
-27
lines changed Original file line number Diff line number Diff line change @@ -48,33 +48,6 @@ func TestSSE(t *testing.T) {
48
48
postsRepository : postsRepositoryMock {},
49
49
})
50
50
51
- postStreamAdapterFunc := http .NewOneModelStreamAdapter (
52
- func (r * netHTTP.Request ) (response Post , err error ) {
53
- postID := chi .URLParam (r , "id" )
54
-
55
- post , err := postsRepositoryMock {}.ByID (postID )
56
- if err != nil {
57
- return Post {}, err
58
- }
59
-
60
- return post , nil
61
- },
62
- func (r * netHTTP.Request , msg * message.Message ) (ok bool ) {
63
- postUpdated := PostUpdated {}
64
-
65
- err := json .Unmarshal (msg .Payload , & postUpdated )
66
- if err != nil {
67
- return false
68
- }
69
-
70
- postID := chi .URLParam (r , "id" )
71
-
72
- return postUpdated .ID == postID
73
- },
74
- )
75
-
76
- _ = postStreamAdapterFunc
77
-
78
51
ctx , cancel := context .WithCancel (context .Background ())
79
52
defer cancel ()
80
53
You can’t perform that action at this time.
0 commit comments