cached_network_image 1.0.0

A rust library to show images from the internet and keep them in the cache.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46

use crate::{
  store::{Image, ImageStore},
  RequestPaint
};

pub struct TaskQueue<I> {
  queue: flume::Sender<I>,
  ready: flume::Receiver<(I, Vec<u8>)>,
  handle: std::thread::JoinHandle<()>,
}

impl<I> TaskQueue<I>
where
  I: Send + Sync + 'static,
{
  pub fn new<R, F>(repaint: R, spawn: F, store: ImageStore<Image>) -> Self
  where
    R: RequestPaint + 'static,
    F: FnOnce(R, flume::Receiver<I>, flume::Sender<(I, Vec<u8>)>, ImageStore<Image>) + Send + Sync + 'static,
  {
    let (queue_tx, queue_rx) = flume::unbounded();
    let (ready_tx, ready_rx) = flume::unbounded();

    let handle = std::thread::spawn(move || spawn(repaint, queue_rx, ready_tx, store));

    Self {
      queue: queue_tx,
      ready: ready_rx,
      handle,
    }
  }

  pub fn join(self) -> Vec<(I, Vec<u8>)> {
    drop(self.queue);
    let _ = self.handle.join();
    self.ready.into_iter().collect()
  }

  pub fn enqueue(&self, item: I) {
    let _ = self.queue.send(item);
  }

  pub fn try_next(&self) -> Option<(I, Vec<u8>)> {
    self.ready.try_recv().ok()
  }
}