Skip to main content

github_queue_reader

maelstrom_util::net

Function github_queue_reader 

Source 
pub async fn github_queue_reader<MessageT, TransformedT>(
    queue: &mut GitHubReadQueue,
    channel: UnboundedSender<TransformedT>,
    transform: impl Fn(MessageT) -> TransformedT,
    log: Logger,
    context: &'static str,
) -> Result<()>
where
    MessageT: Debug + DeserializeOwned,