remcowesterhoud

package Twitter_streams

import java.util.concurrent.{ConcurrentLinkedQueue, ExecutorService, Executors}

import akka.actor.ActorSystem
import akka.event.{Logging, LoggingAdapter}
import akka.{Done, NotUsed}
import akka.stream.ActorMaterializer
import akka.stream.scaladsl.{Flow, Sink, Source}
import twitter4j.{ResponseList, Twitter, TwitterFactory, User}

remcowesterhoud

"""
Behave runner for running features asynchronously.
"""
from multiprocessing import Pool
from subprocess import call, Popen, PIPE
from glob import glob
import logging
import argparse
import json
from functools import partial