37b1d6ab1d
Implement cancellation for watching
2022-06-04 22:54:03 -04:00
2f5495bb80
Change spawner to use Arc
2022-06-04 19:54:07 -04:00
e23dad1f41
Ensure that stream_new_messages returns something that is Send
...
Makes sure that this can be used on multi-threaded executors
Well, technically it doesn't fully guarantee it, but the error
being non-Send is very unlikely. Anyway, if the returned Stream
is not Send, the future definitely won't be, so we will assert
that at least.
2022-06-01 23:08:23 -04:00
80381811bc
Don't use AsRef, use Arc instead to be explicit
2022-06-01 23:06:19 -04:00
d7522fc005
Don't clone SessionGenerators between usages
2022-05-31 01:23:40 -04:00
5fc2c37d90
Remove SequenceNumberStreamer
2022-05-31 01:01:39 -04:00
1a95f53cfc
Remove no longer necessary pub use's
...
these were previously used to facilitate 'main'
2022-05-30 16:48:23 -04:00
abe6cc26fd
Move tokio spawner to testutil mod
2022-05-30 16:48:23 -04:00
d26e15258d
Remove trait bounds from struct/enum definitions
2022-05-30 16:41:13 -04:00
5a49696cfa
Refactor usage of Broker to be behind a facade function
2022-05-30 16:21:47 -04:00
49d3558d9c
Add top-level facade for message streaming
2022-05-30 13:25:12 -04:00
74e6e1a8e6
minor cleanup of Watcher
2022-05-30 01:23:46 -04:00
d9c44bdd43
Remove unneeded Sync bound
2022-05-29 23:59:38 -04:00
71a7f57048
Change fetcher to not parse messages at all
2022-05-29 23:14:11 -04:00
fd6b53a670
Add timeout to broker test
2022-05-21 10:22:50 -04:00
3417870edb
Refactor broker to separate task data into its own structure
2022-05-21 10:20:05 -04:00
ca69471067
Add basic implementation of Broker
2022-05-21 09:39:56 -04:00
47352c6038
Move message fetching into a trait
2022-05-17 23:32:55 -04:00
b2a1d72ce1
Clean up get_idler_cell
2022-05-16 21:08:58 -04:00
9dec076a07
Satisfy clippy and minor cleanups
2022-05-16 21:08:58 -04:00
ef2c603778
Major refactor of watcher logic to be more generic
...
This is setup to allow for swapping out the message generation logic with mocks and other more easily testable data
2022-05-16 21:08:57 -04:00
6d3505a960
Clean up use of generics on Session
2022-05-12 18:38:08 -04:00
4409abd1fa
Break out watching/printing into thier own structures
...
Still crude, but a step in the right direction
2022-05-11 21:25:01 -04:00
2da2859e9b
Add (crude) initial prototype to fetch new emails
2022-05-08 14:02:40 -04:00
a5573eb320
Add config struct
2022-05-05 22:08:53 -04:00
