dgllghr

use bytes::Buf;
use std::io;
use tokio::prelude::*;

pub struct ReadStream<B> {
    max_record_size: usize,
    inbuf: Vec<u8>,
    inbuf_offset: usize,
    outbuf: Vec<u8>,
    outbuf_offset: usize,

dgllghr

package akka.contrib.pattern

import java.util.UUID

import akka.actor.{Actor, ActorLogging, ActorRef, Cancellable}
import akka.serialization.SerializationExtension

import scala.collection.mutable
import scala.concurrent.ExecutionContext
import scala.concurrent.duration._