Permalink
Commits on Apr 15, 2016
  1. Converts the Scan-operation from PushPullStage to GraphStage

    viktorklang committed Apr 14, 2016
Commits on Apr 4, 2016
  1. =str - Improves performance of mapAsync

    * Removes allocations
    
    * Removes indirections & shortens code paths
    viktorklang committed with ktoso Apr 4, 2016
Commits on Feb 17, 2016
  1. =str - #19774 - Implements GSL.readN properly, with tests

    viktorklang committed Feb 17, 2016
  2. Unbreak master by fixing StreamFileDocSpec to import scaladsl._ iso io._

    viktorklang committed Feb 17, 2016
Commits on Feb 15, 2016
  1. = - Minor cleanups, will get an appropriate commit message soon

    viktorklang committed Feb 15, 2016
Commits on Feb 10, 2016
  1. =str - removing superfluous try-catch in stream-customize.rst

    viktorklang committed Feb 10, 2016
Commits on Feb 1, 2016
  1. =str - Minor improvements to Framing

    viktorklang committed Feb 1, 2016
Commits on Jan 25, 2016
  1. =str - Sprinkles some finals in Tcp and improves docs in Flow

    viktorklang committed Jan 25, 2016
Commits on Jan 19, 2016
  1. Minor streams touchups

    viktorklang committed Jan 18, 2016
Commits on Jan 12, 2016
  1. =str - Change implementation of Source.repeat to use unfold

    viktorklang committed Jan 12, 2016
  2. -str - Removes Source.unfoldInf

    Motivation: Since it can be easily implemented inline on top of unfold
    viktorklang committed Jan 11, 2016
Commits on Jan 6, 2016
  1. =str - 16503 - Implements a dedicated FutureSource

    Avoids the overhead of
    `Source.single(future).mapAsyncUnordered(1)(identity).withAttr…`
    
    Fixes #16503
    viktorklang committed Jan 6, 2016
Commits on Jan 2, 2016
  1. =str - 19327 - Fixes race condition in InputStreamSinkSpec

    + Cleanup of that spec
    viktorklang committed Jan 2, 2016
Commits on Dec 22, 2015
  1. =str - Adds minor touchups to Unfold & UnfoldAsync

    * Makes the classes final
    * Sprinkles pixiedust
    * Switches to ScalaFutures in the test
    viktorklang committed with rkuhn Dec 14, 2015
Commits on Dec 12, 2015
  1. =str - 19149 - Corrects the behavior of FlowOps.sliding

    Generatively attempts to verify that it behaves exactly like the
    collections library
    
    Removes the use of Vector.builder for an easier-to-follow Vector
    implementation while waiting for this to be reimplemented as a
    GraphStage.
    
    Also, the Builder implementation relies on undefined behavior:
    
    "Builder.result() — Produces a collection from the added elements.
    The builder's contents are undefined after this operation." -
    http://www.scala-lang.org/api/current/#scala.collection.mutable.Builder
    viktorklang committed Dec 12, 2015
Commits on Dec 11, 2015
  1. =str&http - 19142 - Renames all occurrences of `mat` with `materializer`

    (When referring to a Materializer)
    viktorklang committed Dec 11, 2015
Commits on Dec 9, 2015
  1. Merge pull request #19136 from akka/wip-avoid-npe-√

    =str - Avoids an NPE in LocalSource.pull
    viktorklang committed Dec 9, 2015
Commits on Dec 8, 2015
  1. Merge pull request #19116 from akka/wip-19028-require-min-ports-√

    !str - 19028 - Adds requirements for minimum ports
    viktorklang committed Dec 8, 2015
  2. Merge pull request #19121 from 2m/wip-input-stream-pub-alloc

    =str remove unused buffer pool
    viktorklang committed Dec 8, 2015
  3. Merge pull request #19123 from akka/wip-19109-unbreak-sinkforeachpara…

    …llelspec-√
    
    =str - 19109 - Unbreaking SinkForeachParallelSpec
    viktorklang committed Dec 8, 2015
  4. Merge pull request #19120 from akka/wip-19091-remove-buffer-in-bluepr…

    …int-√
    
    =http - 19091 - Removes the buffer(1, Backpressure) from the Http blu…
    viktorklang committed Dec 8, 2015
Commits on Dec 7, 2015
  1. !str - 19028 - Adds requirements for minimum ports

    Broadcast == min output ports: 2
    Merge == min input ports: 2
    MergePreferred == min secondary ports: 1
    Concat == min input ports: 2
    viktorklang committed Dec 7, 2015
Commits on Nov 18, 2015
  1. Merge pull request #18951 from akka/wip-add-sink-last-√

    +str - Adds Sink.last and Sink.lastOption to mirror Sink.head and Sin…
    viktorklang committed Nov 18, 2015
  2. +str - Adds Sink.last and Sink.lastOption to mirror Sink.head and Sin…

    …k.headOption
    
    * Renames BlackholeSubscriber to SinkholeSunbscriber
    * Makes SinkholeSubscriber request Long.MaxValue
    * SinkholeSink seems like the best name ever
    viktorklang committed Nov 17, 2015
Commits on Nov 17, 2015
  1. !str - 18916 - Source.file and Sink.file

    * Removes `Synchronous` from the names and descriptions of File I/O as it leaks impl details
    * Removes the factries for FileSource and FileSink and puts them in Source and Sink respectively
    viktorklang committed Nov 14, 2015
Commits on Nov 4, 2015
  1. !str - Switches Sink.publisher to use a boolean to indicate fanout ra…

    …ther than a number of allowed subscribers
    viktorklang committed Nov 3, 2015
  2. !str - 18808 - Removes Sink.fanoutPublisher and makes Sink.publisher …

    …specify number of subscribers
    
    Sink.publisher now takes a max number of Subscribers and
    the elasticity between concurrent Subscribers.
    viktorklang committed Oct 30, 2015