izderadicka

#[macro_use]
extern crate log;

use hyper::rt;
use hyper::server::Server;
use hyper::service::service_fn_ok;
use hyper::{Body, Request, Response};
use tokio::prelude::*;

mod ws;

izderadicka

use std::io::{self, Write, Seek};

pub struct Writer<W> {
    inner: W
}


impl <W:Write> Writer<WrapperUnseekable<W>> {
    pub fn new_unseekable(inner: W) -> Self {
        Writer{

izderadicka

#[macro_use]
extern crate log;
use futures::prelude::*;
use futures::stream::StreamExt;
use headers::{self, HeaderMapExt};
use hyper::header::{self, AsHeaderName, HeaderMap, HeaderValue};
use hyper::server::Server;
use hyper::service::{make_service_fn, service_fn};
use hyper::{self, Body, Method, Request, Response, StatusCode};
use std::convert::Infallible;

izderadicka

Contains coverage information for project dstream

coverage report

izderadicka

izderadicka

use std::{borrow::Cow, collections::HashMap, hash::Hash};

pub struct CowMap<'a, T, K, V>
where
    K: ToOwned<Owned = T> + ?Sized,
{
    map: HashMap<Cow<'a, K>, V>,
}

impl<'a, T, K, V> CowMap<'a, T, K, V>

izderadicka

import streamlit as st
import pandas as pd
import numpy as np
import plotly.express as px

st.set_page_config(layout="wide")

DATE_COLUMN = 'date/time'
DATA_URL = ('https://s3-us-west-2.amazonaws.com/'
         'streamlit-demo-data/uber-raw-data-sep14.csv.gz')