anna/async-graphql
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fixed code formatting

Browse Source
This commit is contained in:
D1plo1d 2021-03-31 20:57:39 -04:00
parent cfb6246e52
commit e6da885093
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
integrations/warp/src/subscription.rs
View File

@ -100,9 +100,7 @@ where
ws_receiver ws_receiver
.take_while(|msg| future::ready(msg.is_ok())) .take_while(|msg| future::ready(msg.is_ok()))
.map(Result::unwrap) .map(Result::unwrap)
.filter(|msg | { .filter(|msg| future::ready(msg.is_text() || msg.is_binary()))
future::ready(msg.is_text() || msg.is_binary())
})
.map(ws::Message::into_bytes), .map(ws::Message::into_bytes),
initializer, initializer,
protocol, protocol,