Commit Graph

65 Commits

Author SHA1 Message Date
Andrey Tkachenko
7fbbed15d8 ProducerHandler 2023-02-24 11:59:30 +04:00
Andrey Tkachenko
bc759001d3 Mutable TaskHandler 2023-02-20 13:39:09 +04:00
2423802ecd Queue story
Some checks failed
continuous-integration/drone/push Build is failing
2023-02-17 21:40:45 +04:00
b4b58a9be0 MessageBus Next 2023-02-16 18:10:34 +04:00
1d898b8257 Enable CI
All checks were successful
continuous-integration/drone/push Build is passing
2022-03-17 15:27:17 +04:00
73aeefb46f Rework idle detection 2021-12-16 16:12:28 +04:00
b06eac6504 Fix deadlock bug with flush 2021-12-03 15:30:13 +04:00
c9f03f5b49 AsyncProducer Handler update + version bump 2021-11-25 16:48:41 +04:00
c927dad70e Flush&Sync per message type; Rewrite select receivers; 2021-11-15 20:01:28 +04:00
18bd3c63f4 Tcp relay update; refactoring type tag 2021-11-05 18:39:25 +04:00
bc862cfac6 TCP Relay 2021-10-08 13:03:24 +04:00
1bff5cc70a try_clone 2021-09-29 15:00:35 +04:00
7034e8b87b Bump version 2021-09-28 16:42:09 +04:00
535c39c9dc Redis begin & fixes for QUIC 2021-09-28 15:19:44 +04:00
73763f8a9d add receiver id & remote quic progress 2021-09-24 19:46:23 +04:00
3a0a1019b6 fix message requirement 2021-09-24 13:13:29 +04:00
16690db44c revert upgrate to 2021 edition 2021-09-24 12:47:01 +04:00
bed35670c6 refactor senderror 2021-09-22 17:07:21 +04:00
5ba6f1139d Fix test_relay.rs 2021-09-22 16:53:21 +04:00
79a4441bfd Fix derive sharedmessage namespace 2021-09-22 16:50:30 +04:00
6ef65cbfd1 QUIC Relay progress 2021-09-22 16:48:28 +04:00
22d1d4a569 make clippy happy 2021-09-21 14:47:21 +04:00
9d014d38a1 Refacroting ReciveTypedReceiver 2021-09-20 19:31:06 +04:00
ce64f7f4bc fmt + bechmark example 2021-09-20 17:20:00 +04:00
5c03068c79 QUIC Client Relay progress 2021-09-16 19:04:34 +04:00
a0544f01e4 MessageBus Remote split out; crate reorganization 2021-09-16 16:51:13 +04:00
c9ea551e0d remove sync deadline 2021-09-16 13:57:47 +04:00
ac12bb08ab cleanup receivers 2021-09-16 13:19:28 +04:00
81e5376fe2 refactoring receivers +speed ++clean 2021-09-15 19:54:59 +04:00
da6dc04f71 fix major bug with sync& version bump 2021-09-15 13:33:25 +04:00
21e28ffa12 fix flush 2021-09-07 19:02:29 +04:00
e81a70a197 version bump 2021-09-03 18:57:09 +04:00
c2e67bfcbd minor gug fixes 2021-09-03 18:46:56 +04:00
73cf59afb8 add request_boxed_we 2021-08-20 17:18:56 +04:00
7332c04e53 Add request_boxed_we 2021-08-12 13:16:30 +04:00
6d8dd039b3 Derive TypeTagged correctly 2021-08-10 14:24:28 +04:00
ba67c8251d Add TypeTagged bound for Message derive generics 2021-08-09 18:27:25 +04:00
c47657177c Init event & relays continue 2021-08-04 19:14:56 +04:00
db34774acd Quic relay begin 2021-08-03 13:41:30 +04:00
9a887d4821 Relays + example (test) 2021-07-30 16:59:14 +04:00
3bb2fe7492 Relays: rewrite relay trat 2021-07-29 17:23:08 +04:00
993ff4a46d Relay unification with Receivers 2021-07-23 17:29:47 +04:00
640a8ceee1 SerDe Messages and RelayTrait update 2021-07-20 16:04:10 +04:00
13d1d48a70 Relays: Message and SharedMessage; messagebus_derive 2021-07-16 20:21:27 +04:00
76cc57e7ae Generalize over batch type; subscribe_{sync|async} methods; relays begin 2021-07-02 20:21:53 +04:00
308939801b Add CHANGELOG.md 2021-06-29 13:41:51 +04:00
908059d8c9 Add send_one, send_one_blocked, try_send_one 2021-06-29 13:25:03 +04:00
48756264b8 Cleanup 2021-06-28 19:39:58 +04:00
655fdf8462 Add modules 2021-06-28 19:37:53 +04:00
f51433557e Update error handling 2021-06-28 17:49:34 +04:00