Last active
January 11, 2016 19:50
-
-
Save ktoso/5e734431a4c5c9c8ddff to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| master-of-the-streams!akka-second $> diff --stat ce691b48eeaa5adbbec42015605d33f9ebc6ce1b | |
| akka-docs-dev/_sphinx/exts/includecode.py | 145 ++ | |
| akka-docs-dev/_sphinx/exts/includecode2.py | 109 ++ | |
| akka-docs-dev/_sphinx/pygments/setup.py | 19 + | |
| akka-docs-dev/_sphinx/pygments/styles/__init__.py | 0 | |
| akka-docs-dev/_sphinx/pygments/styles/simple.py | 58 + | |
| akka-docs-dev/_sphinx/static/akka-intellij-code-style.jar | Bin 0 -> 8587 bytes | |
| akka-docs-dev/_sphinx/static/akka.png | Bin 0 -> 10746 bytes | |
| akka-docs-dev/_sphinx/static/favicon.ico | Bin 0 -> 26683 bytes | |
| akka-docs-dev/_sphinx/static/logo.png | Bin 0 -> 10746 bytes | |
| akka-docs-dev/_sphinx/themes/akka/layout.html | 371 ++++++ | |
| akka-docs-dev/_sphinx/themes/akka/static/akka_full_color.svg | 1 + | |
| akka-docs-dev/_sphinx/themes/akka/static/akka_icon_full_color.svg | 1 + | |
| akka-docs-dev/_sphinx/themes/akka/static/akka_icon_reverse.svg | 1 + | |
| akka-docs-dev/_sphinx/themes/akka/static/akka_reverse.svg | 1 + | |
| akka-docs-dev/_sphinx/themes/akka/static/base.css | 94 ++ | |
| akka-docs-dev/_sphinx/themes/akka/static/contentsFix.js | 10 + | |
| akka-docs-dev/_sphinx/themes/akka/static/docs.css | 222 ++++ | |
| akka-docs-dev/_sphinx/themes/akka/static/effects.core.js | 509 +++++++ | |
| akka-docs-dev/_sphinx/themes/akka/static/effects.highlight.js | 48 + | |
| akka-docs-dev/_sphinx/themes/akka/static/ga.js | 43 + | |
| akka-docs-dev/_sphinx/themes/akka/static/highlightCode.js | 13 + | |
| akka-docs-dev/_sphinx/themes/akka/static/jquery.js | 4 + | |
| akka-docs-dev/_sphinx/themes/akka/static/logo-small.png | Bin 0 -> 946 bytes | |
| akka-docs-dev/_sphinx/themes/akka/static/pdf-icon.png | Bin 0 -> 15170 bytes | |
| akka-docs-dev/_sphinx/themes/akka/static/pdf-java-icon.png | Bin 0 -> 18845 bytes | |
| akka-docs-dev/_sphinx/themes/akka/static/pdf-scala-icon.png | Bin 0 -> 19064 bytes | |
| akka-docs-dev/_sphinx/themes/akka/static/prettify.css | 43 + | |
| akka-docs-dev/_sphinx/themes/akka/static/prettify.js | 28 + | |
| akka-docs-dev/_sphinx/themes/akka/static/scrollTo.js | 9 + | |
| akka-docs-dev/_sphinx/themes/akka/static/style.css | 629 +++++++++ | |
| akka-docs-dev/_sphinx/themes/akka/static/toc.js | 131 ++ | |
| akka-docs-dev/_sphinx/themes/akka/static/watermark.png | Bin 0 -> 2442 bytes | |
| akka-docs-dev/_sphinx/themes/akka/theme.conf | 6 + | |
| akka-docs-dev/rst/conf.py | 87 ++ | |
| akka-docs-dev/rst/images/akka-http-file-listing.png | Bin 0 -> 14424 bytes | |
| akka-docs-dev/rst/images/asyncBoundary.png | Bin 0 -> 455426 bytes | |
| akka-docs-dev/rst/images/compose_attributes.png | Bin 0 -> 27714 bytes | |
| akka-docs-dev/rst/images/compose_composites.png | Bin 0 -> 24672 bytes | |
| akka-docs-dev/rst/images/compose_graph.png | Bin 0 -> 13782 bytes | |
| akka-docs-dev/rst/images/compose_graph_flow.png | Bin 0 -> 10501 bytes | |
| akka-docs-dev/rst/images/compose_graph_partial.png | Bin 0 -> 11703 bytes | |
| akka-docs-dev/rst/images/compose_graph_shape.png | Bin 0 -> 15571 bytes | |
| akka-docs-dev/rst/images/compose_mat.png | Bin 0 -> 20216 bytes | |
| akka-docs-dev/rst/images/compose_nested_flow.png | Bin 0 -> 9632 bytes | |
| akka-docs-dev/rst/images/compose_nested_flow_opaque.png | Bin 0 -> 7703 bytes | |
| akka-docs-dev/rst/images/compose_shapes.png | Bin 0 -> 9603 bytes | |
| akka-docs-dev/rst/images/composition.png | Bin 0 -> 62480 bytes | |
| akka-docs-dev/rst/images/composition.svg | 6771 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ | |
| akka-docs-dev/rst/images/graph_stage_chain.png | Bin 0 -> 208849 bytes | |
| akka-docs-dev/rst/images/graph_stage_chain.svg | 3 + | |
| akka-docs-dev/rst/images/graph_stage_conceptual.png | Bin 0 -> 99027 bytes | |
| akka-docs-dev/rst/images/graph_stage_conceptual.svg | 3 + | |
| akka-docs-dev/rst/images/graph_stage_detached_tracks_1.png | Bin 0 -> 110635 bytes | |
| akka-docs-dev/rst/images/graph_stage_detached_tracks_1.svg | 3 + | |
| akka-docs-dev/rst/images/graph_stage_detached_tracks_2.png | Bin 0 -> 104498 bytes | |
| akka-docs-dev/rst/images/graph_stage_detached_tracks_2.svg | 3 + | |
| akka-docs-dev/rst/images/graph_stage_duplicate.png | Bin 0 -> 72710 bytes | |
| akka-docs-dev/rst/images/graph_stage_duplicate.svg | 3 + | |
| akka-docs-dev/rst/images/graph_stage_filter.png | Bin 0 -> 71049 bytes | |
| akka-docs-dev/rst/images/graph_stage_filter.svg | 3 + | |
| akka-docs-dev/rst/images/graph_stage_map.png | Bin 0 -> 58039 bytes | |
| akka-docs-dev/rst/images/graph_stage_map.svg | 3 + | |
| akka-docs-dev/rst/images/graph_stage_tracks_1.png | Bin 0 -> 201074 bytes | |
| akka-docs-dev/rst/images/graph_stage_tracks_1.svg | 3 + | |
| akka-docs-dev/rst/images/inport_transitions.png | Bin 0 -> 67982 bytes | |
| akka-docs-dev/rst/images/outport_transitions.png | Bin 0 -> 30528 bytes | |
| akka-docs-dev/rst/images/port_transitions.svg | 1054 +++++++++++++++ | |
| akka-docs-dev/rst/images/simple-graph-example.png | Bin 0 -> 16476 bytes | |
| akka-docs-dev/rst/images/stage_chain.png | Bin 0 -> 28293 bytes | |
| akka-docs-dev/rst/images/stage_conceptual.png | Bin 0 -> 22739 bytes | |
| akka-docs-dev/rst/images/stage_doubler.png | Bin 0 -> 18225 bytes | |
| akka-docs-dev/rst/images/stage_filter.png | Bin 0 -> 16165 bytes | |
| akka-docs-dev/rst/images/stage_map.png | Bin 0 -> 12562 bytes | |
| akka-docs-dev/rst/images/stage_msc_absorb_1.png | Bin 0 -> 37948 bytes | |
| akka-docs-dev/rst/images/stage_msc_absorb_2.png | Bin 0 -> 37500 bytes | |
| akka-docs-dev/rst/images/stage_msc_buffer.png | Bin 0 -> 58128 bytes | |
| akka-docs-dev/rst/images/stage_msc_general.png | Bin 0 -> 44337 bytes | |
| akka-docs-dev/rst/images/stages.svg | 1124 ++++++++++++++++ | |
| akka-docs-dev/rst/images/stages_sequence_charts.svg | 2310 ++++++++++++++++++++++++++++++++ | |
| akka-docs-dev/rst/index.rst | 8 + | |
| akka-docs-dev/rst/java.rst | 10 + | |
| akka-docs-dev/rst/java/code/docs/MigrationsJava.java | 249 ++++ | |
| akka-docs-dev/rst/java/code/docs/http/javadsl/HttpClientExampleDocTest.java | 99 ++ | |
| akka-docs-dev/rst/java/code/docs/http/javadsl/ModelDocTest.java | 90 ++ | |
| akka-docs-dev/rst/java/code/docs/http/javadsl/server/FormFieldRequestValsExampleTest.java | 76 ++ | |
| akka-docs-dev/rst/java/code/docs/http/javadsl/server/HeaderRequestValsExampleTest.java | 63 + | |
| akka-docs-dev/rst/java/code/docs/http/javadsl/server/HighLevelServerBindFailureExample.java | 39 + | |
| akka-docs-dev/rst/java/code/docs/http/javadsl/server/HighLevelServerExample.java | 69 + | |
| akka-docs-dev/rst/java/code/docs/http/javadsl/server/HttpBasicAuthenticatorExample.java | 74 ++ | |
| akka-docs-dev/rst/java/code/docs/http/javadsl/server/HttpServerExampleDocTest.java | 245 ++++ | |
| akka-docs-dev/rst/java/code/docs/http/javadsl/server/OAuth2AuthenticatorExample.java | 81 ++ | |
| akka-docs-dev/rst/java/code/docs/http/javadsl/server/PathDirectiveExampleTest.java | 77 ++ | |
| akka-docs-dev/rst/java/code/docs/http/javadsl/server/WebsocketCoreExample.java | 96 ++ | |
| akka-docs-dev/rst/java/code/docs/http/javadsl/server/WebsocketRoutingExample.java | 54 + | |
| akka-docs-dev/rst/java/code/docs/http/javadsl/server/directives/HostDirectivesExamplesTest.java | 99 ++ | |
| akka-docs-dev/rst/java/code/docs/http/javadsl/server/directives/MethodDirectivesExamplesTest.java | 124 ++ | |
| akka-docs-dev/rst/java/code/docs/http/javadsl/server/testkit/MyAppService.java | 33 + | |
| akka-docs-dev/rst/java/code/docs/http/javadsl/server/testkit/TestkitExampleTest.java | 36 + | |
| akka-docs-dev/rst/java/http/client-side/connection-level.rst | 80 ++ | |
| akka-docs-dev/rst/java/http/client-side/host-level.rst | 151 +++ | |
| akka-docs-dev/rst/java/http/client-side/https-support.rst | 65 + | |
| akka-docs-dev/rst/java/http/client-side/index.rst | 30 + | |
| akka-docs-dev/rst/java/http/client-side/request-level.rst | 73 + | |
| akka-docs-dev/rst/java/http/client-side/websocket-support.rst | 8 + | |
| akka-docs-dev/rst/java/http/configuration.rst | 28 + | |
| akka-docs-dev/rst/java/http/http-model.rst | 270 ++++ | |
| akka-docs-dev/rst/java/http/index.rst | 41 + | |
| akka-docs-dev/rst/java/http/routing-dsl/directives/host-directives/extractHost.rst | 13 + | |
| akka-docs-dev/rst/java/http/routing-dsl/directives/host-directives/host.rst | 44 + | |
| akka-docs-dev/rst/java/http/routing-dsl/directives/host-directives/index.rst | 15 + | |
| akka-docs-dev/rst/java/http/routing-dsl/directives/index.rst | 70 + | |
| akka-docs-dev/rst/java/http/routing-dsl/directives/method-directives/delete.rst | 17 + | |
| akka-docs-dev/rst/java/http/routing-dsl/directives/method-directives/extractMethod.rst | 16 + | |
| akka-docs-dev/rst/java/http/routing-dsl/directives/method-directives/get.rst | 17 + | |
| akka-docs-dev/rst/java/http/routing-dsl/directives/method-directives/head.rst | 20 + | |
| akka-docs-dev/rst/java/http/routing-dsl/directives/method-directives/index.rst | 18 + | |
| akka-docs-dev/rst/java/http/routing-dsl/directives/method-directives/method.rst | 19 + | |
| akka-docs-dev/rst/java/http/routing-dsl/directives/method-directives/options.rst | 16 + | |
| akka-docs-dev/rst/java/http/routing-dsl/directives/method-directives/overrideMethodWithParameter.rst | 11 + | |
| akka-docs-dev/rst/java/http/routing-dsl/directives/method-directives/patch.rst | 17 + | |
| akka-docs-dev/rst/java/http/routing-dsl/directives/method-directives/post.rst | 17 + | |
| akka-docs-dev/rst/java/http/routing-dsl/directives/method-directives/put.rst | 16 + | |
| akka-docs-dev/rst/java/http/routing-dsl/directives/path-directives.rst | 95 ++ | |
| akka-docs-dev/rst/java/http/routing-dsl/handlers.rst | 142 ++ | |
| akka-docs-dev/rst/java/http/routing-dsl/index.rst | 18 + | |
| akka-docs-dev/rst/java/http/routing-dsl/json-support.rst | 31 + | |
| akka-docs-dev/rst/java/http/routing-dsl/marshalling.rst | 43 + | |
| akka-docs-dev/rst/java/http/routing-dsl/overview.rst | 100 ++ | |
| akka-docs-dev/rst/java/http/routing-dsl/request-vals/form-field-request-vals.rst | 26 + | |
| akka-docs-dev/rst/java/http/routing-dsl/request-vals/header-request-vals.rst | 33 + | |
| akka-docs-dev/rst/java/http/routing-dsl/request-vals/http-basic-authenticator.rst | 38 + | |
| akka-docs-dev/rst/java/http/routing-dsl/request-vals/index.rst | 60 + | |
| akka-docs-dev/rst/java/http/routing-dsl/request-vals/oauth2-authenticator.rst | 47 + | |
| akka-docs-dev/rst/java/http/routing-dsl/routes.rst | 90 ++ | |
| akka-docs-dev/rst/java/http/routing-dsl/testkit.rst | 80 ++ | |
| akka-docs-dev/rst/java/http/server-side/low-level-server-side-api.rst | 228 ++++ | |
| akka-docs-dev/rst/java/http/server-side/websocket-support.rst | 126 ++ | |
| akka-docs-dev/rst/java/migration-guide-1.0-2.x-java.rst | 715 ++++++++++ | |
| akka-docs-dev/rst/java/stream-composition.rst | 310 +++++ | |
| akka-docs-dev/rst/java/stream-cookbook.rst | 390 ++++++ | |
| akka-docs-dev/rst/java/stream-customize.rst | 434 ++++++ | |
| akka-docs-dev/rst/java/stream-error.rst | 79 ++ | |
| akka-docs-dev/rst/java/stream-flows-and-basics.rst | 313 +++++ | |
| akka-docs-dev/rst/java/stream-graphs.rst | 310 +++++ | |
| akka-docs-dev/rst/java/stream-index.rst | 25 + | |
| akka-docs-dev/rst/java/stream-integrations.rst | 440 ++++++ | |
| akka-docs-dev/rst/java/stream-introduction.rst | 85 ++ | |
| akka-docs-dev/rst/java/stream-io.rst | 124 ++ | |
| akka-docs-dev/rst/java/stream-parallelism.rst | 103 ++ | |
| akka-docs-dev/rst/java/stream-quickstart.rst | 199 +++ | |
| akka-docs-dev/rst/java/stream-rate.rst | 169 +++ | |
| akka-docs-dev/rst/java/stream-testkit.rst | 100 ++ | |
| akka-docs-dev/rst/scala.rst | 10 + | |
| akka-docs-dev/rst/scala/code/docs/MigrationsScala.scala | 281 ++++ | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/HttpClientExampleSpec.scala | 108 ++ | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/HttpServerExampleSpec.scala | 398 ++++++ | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/HttpServerExampleSpec.scala.orig | 407 ++++++ | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/MarshalSpec.scala | 38 + | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/ModelSpec.scala | 91 ++ | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/SprayJsonExampleSpec.scala | 50 + | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/UnmarshalSpec.scala | 29 + | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/server/CaseClassExtractionExamplesSpec.scala | 82 ++ | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/server/DirectiveExamplesSpec.scala | 109 ++ | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/server/ExceptionHandlerExamplesSpec.scala | 95 ++ | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/server/FileUploadExamplesSpec.scala | 96 ++ | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/server/FullTestKitExampleSpec.scala | 62 + | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/server/RejectionHandlerExamplesSpec.scala | 79 ++ | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/server/RoutingSpec.scala | 11 + | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/server/WebsocketExampleSpec.scala | 109 ++ | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/server/directives/BasicDirectivesExamplesSpec.scala | 803 +++++++++++ | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/server/directives/CodingDirectivesExamplesSpec.scala | 126 ++ | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/server/directives/CookieDirectivesExamplesSpec.scala | 70 + | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/server/directives/CustomDirectivesExamplesSpec.scala | 73 + | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/server/directives/DebuggingDirectivesExamplesSpec.scala | 97 ++ | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/server/directives/ExecutionDirectivesExamplesSpec.scala | 62 + | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/server/directives/FileAndResourceDirectivesExamplesSpec.scala | 105 ++ | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/server/directives/FileUploadDirectivesExamplesSpec.scala | 77 ++ | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/server/directives/FormFieldDirectivesExamplesSpec.scala | 48 + | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/server/directives/FutureDirectivesExamplesSpec.scala | 102 ++ | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/server/directives/HeaderDirectivesExamplesSpec.scala | 188 +++ | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/server/directives/HostDirectivesExamplesSpec.scala | 92 ++ | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/server/directives/MarshallingDirectivesExamplesSpec.scala | 86 ++ | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/server/directives/MethodDirectivesExamplesSpec.scala | 136 ++ | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/server/directives/MiscDirectivesExamplesSpec.scala | 96 ++ | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/server/directives/ParameterDirectivesExamplesSpec.scala | 212 +++ | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/server/directives/PathDirectivesExamplesSpec.scala | 380 ++++++ | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/server/directives/RangeDirectivesExamplesSpec.scala | 58 + | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/server/directives/RespondWithDirectivesExamplesSpec.scala | 83 ++ | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/server/directives/RouteDirectivesExamplesSpec.scala | 100 ++ | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/server/directives/SchemeDirectivesExamplesSpec.scala | 46 + | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/server/directives/SecurityDirectivesExamplesSpec.scala | 286 ++++ | |
| akka-docs-dev/rst/scala/code/docs/http/scaladsl/server/directives/WebsocketDirectivesExamplesSpec.scala | 106 ++ | |
| akka-docs-dev/rst/scala/code/docs/stream/ActorPublisherDocSpec.scala | 96 ++ | |
| akka-docs-dev/rst/scala/code/docs/stream/ActorSubscriberDocSpec.scala | 89 ++ | |
| akka-docs-dev/rst/scala/code/docs/stream/BidiFlowDocSpec.scala | 176 +++ | |
| akka-docs-dev/rst/scala/code/docs/stream/CompositionDocSpec.scala | 249 ++++ | |
| akka-docs-dev/rst/scala/code/docs/stream/FlowDocSpec.scala | 248 ++++ | |
| akka-docs-dev/rst/scala/code/docs/stream/FlowErrorDocSpec.scala | 92 ++ | |
| akka-docs-dev/rst/scala/code/docs/stream/FlowGraphDocSpec.scala | 233 ++++ | |
| akka-docs-dev/rst/scala/code/docs/stream/FlowParallelismDocSpec.scala | 110 ++ | |
| akka-docs-dev/rst/scala/code/docs/stream/FlowStagesSpec.scala | 192 +++ | |
| akka-docs-dev/rst/scala/code/docs/stream/GraphCyclesSpec.scala | 110 ++ | |
| akka-docs-dev/rst/scala/code/docs/stream/GraphStageDocSpec.scala | 508 +++++++ | |
| akka-docs-dev/rst/scala/code/docs/stream/IntegrationDocSpec.scala | 379 ++++++ | |
| akka-docs-dev/rst/scala/code/docs/stream/RateTransformationDocSpec.scala | 111 ++ | |
| akka-docs-dev/rst/scala/code/docs/stream/ReactiveStreamsDocSpec.scala | 147 ++ | |
| akka-docs-dev/rst/scala/code/docs/stream/StreamBuffersRateSpec.scala | 89 ++ | |
| akka-docs-dev/rst/scala/code/docs/stream/StreamPartialFlowGraphDocSpec.scala | 130 ++ | |
| akka-docs-dev/rst/scala/code/docs/stream/StreamTestKitDocSpec.scala | 161 +++ | |
| akka-docs-dev/rst/scala/code/docs/stream/TwitterStreamQuickstartDocSpec.scala | 210 +++ | |
| akka-docs-dev/rst/scala/code/docs/stream/cookbook/RecipeByteStrings.scala | 100 ++ | |
| akka-docs-dev/rst/scala/code/docs/stream/cookbook/RecipeCollectingMetrics.scala | 90 ++ | |
| akka-docs-dev/rst/scala/code/docs/stream/cookbook/RecipeDigest.scala | 62 + | |
| akka-docs-dev/rst/scala/code/docs/stream/cookbook/RecipeDroppyBroadcast.scala | 65 + | |
| akka-docs-dev/rst/scala/code/docs/stream/cookbook/RecipeFlattenSeq.scala | 28 + | |
| akka-docs-dev/rst/scala/code/docs/stream/cookbook/RecipeGlobalRateLimit.scala | 135 ++ | |
| akka-docs-dev/rst/scala/code/docs/stream/cookbook/RecipeHold.scala | 115 ++ | |
| akka-docs-dev/rst/scala/code/docs/stream/cookbook/RecipeKeepAlive.scala | 25 + | |
| akka-docs-dev/rst/scala/code/docs/stream/cookbook/RecipeLoggingElements.scala | 50 + | |
| akka-docs-dev/rst/scala/code/docs/stream/cookbook/RecipeManualTrigger.scala | 93 ++ | |
| akka-docs-dev/rst/scala/code/docs/stream/cookbook/RecipeMissedTicks.scala | 57 + | |
| akka-docs-dev/rst/scala/code/docs/stream/cookbook/RecipeMultiGroupBy.scala | 58 + | |
| akka-docs-dev/rst/scala/code/docs/stream/cookbook/RecipeParseLines.scala | 39 + | |
| akka-docs-dev/rst/scala/code/docs/stream/cookbook/RecipeReduceByKey.scala | 81 ++ | |
| akka-docs-dev/rst/scala/code/docs/stream/cookbook/RecipeSimpleDrop.scala | 49 + | |
| akka-docs-dev/rst/scala/code/docs/stream/cookbook/RecipeSpec.scala | 13 + | |
| akka-docs-dev/rst/scala/code/docs/stream/cookbook/RecipeToStrict.scala | 27 + | |
| akka-docs-dev/rst/scala/code/docs/stream/cookbook/RecipeWorkerPool.scala | 48 + | |
| akka-docs-dev/rst/scala/code/docs/stream/io/StreamFileDocSpec.scala | 60 + | |
| akka-docs-dev/rst/scala/code/docs/stream/io/StreamTcpDocSpec.scala | 165 +++ | |
| akka-docs-dev/rst/scala/code/docs/utils/TestUtils.scala | 24 + | |
| akka-docs-dev/rst/scala/http/client-side/connection-level.rst | 82 ++ | |
| akka-docs-dev/rst/scala/http/client-side/host-level.rst | 151 +++ | |
| akka-docs-dev/rst/scala/http/client-side/https-support.rst | 64 + | |
| akka-docs-dev/rst/scala/http/client-side/index.rst | 31 + | |
| akka-docs-dev/rst/scala/http/client-side/request-level.rst | 81 ++ | |
| akka-docs-dev/rst/scala/http/client-side/websocket-support.rst | 8 + | |
| akka-docs-dev/rst/scala/http/common/de-coding.rst | 16 + | |
| akka-docs-dev/rst/scala/http/common/http-model.rst | 338 +++++ | |
| akka-docs-dev/rst/scala/http/common/index.rst | 21 + | |
| akka-docs-dev/rst/scala/http/common/json-support.rst | 41 + | |
| akka-docs-dev/rst/scala/http/common/marshalling.rst | 164 +++ | |
| akka-docs-dev/rst/scala/http/common/unmarshalling.rst | 119 ++ | |
| akka-docs-dev/rst/scala/http/common/xml-support.rst | 29 + | |
| akka-docs-dev/rst/scala/http/configuration.rst | 28 + | |
| akka-docs-dev/rst/scala/http/index.rst | 15 + | |
| akka-docs-dev/rst/scala/http/introduction.rst | 32 + | |
| akka-docs-dev/rst/scala/http/low-level-server-side-api.rst | 234 ++++ | |
| akka-docs-dev/rst/scala/http/migration-from-spray.rst | 10 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/case-class-extraction.rst | 68 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/alphabetically.rst | 213 +++ | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/cancelRejection.rst | 27 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/cancelRejections.rst | 29 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/extract.rst | 25 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/extractExecutionContext.rst | 25 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/extractLog.rst | 26 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/extractMaterializer.rst | 24 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/extractRequest.rst | 24 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/extractRequestContext.rst | 27 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/extractSettings.rst | 24 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/extractUnmatchedPath.rst | 26 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/extractUri.rst | 23 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/index.rst | 127 ++ | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/mapInnerRoute.rst | 23 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/mapRejections.rst | 27 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/mapRequest.rst | 27 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/mapRequestContext.rst | 26 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/mapResponse.rst | 31 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/mapResponseEntity.rst | 24 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/mapResponseHeaders.rst | 25 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/mapRouteResult.rst | 25 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/mapRouteResultFuture.rst | 27 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/mapRouteResultPF.rst | 28 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/mapRouteResultWith.rst | 27 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/mapRouteResultWithPF.rst | 28 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/mapSettings.rst | 23 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/mapUnmatchedPath.rst | 25 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/pass.rst | 22 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/provide.rst | 25 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/recoverRejections.rst | 28 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/recoverRejectionsWith.rst | 31 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/textract.rst | 30 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/tprovide.rst | 30 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/withExecutionContext.rst | 25 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/withLog.rst | 25 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/withMaterializer.rst | 25 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/basic-directives/withSettings.rst | 24 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/by-trait.rst | 106 ++ | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/cache-condition-directives/conditional.rst | 40 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/cache-condition-directives/index.rst | 9 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/coding-directives/decodeRequest.rst | 21 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/coding-directives/decodeRequestWith.rst | 21 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/coding-directives/encodeResponse.rst | 27 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/coding-directives/encodeResponseWith.rst | 30 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/coding-directives/index.rst | 14 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/coding-directives/requestEncodedWith.rst | 19 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/coding-directives/responseEncodingAccepted.rst | 21 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/cookie-directives/cookie.rst | 24 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/cookie-directives/deleteCookie.rst | 22 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/cookie-directives/index.rst | 12 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/cookie-directives/optionalCookie.rst | 23 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/cookie-directives/setCookie.rst | 23 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/custom-directives.rst | 196 +++ | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/debugging-directives/index.rst | 11 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/debugging-directives/logRequest.rst | 44 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/debugging-directives/logRequestResult.rst | 34 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/debugging-directives/logResult.rst | 36 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/execution-directives/handleExceptions.rst | 25 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/execution-directives/handleRejections.rst | 24 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/execution-directives/index.rst | 10 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/file-and-resource-directives/getFromBrowseableDirectories.rst | 30 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/file-and-resource-directives/getFromBrowseableDirectory.rst | 51 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/file-and-resource-directives/getFromDirectory.rst | 38 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/file-and-resource-directives/getFromFile.rst | 38 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/file-and-resource-directives/getFromResource.rst | 26 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/file-and-resource-directives/getFromResourceDirectory.rst | 26 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/file-and-resource-directives/index.rst | 24 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/file-and-resource-directives/listDirectoryContents.rst | 31 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/file-upload-directives/fileUpload.rst | 29 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/file-upload-directives/index.rst | 10 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/file-upload-directives/uploadedFile.rst | 31 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/form-field-directives/formField.rst | 22 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/form-field-directives/formFields.rst | 105 ++ | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/form-field-directives/index.rst | 10 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/future-directives/completeOrRecoverWith.rst | 25 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/future-directives/index.rst | 14 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/future-directives/onComplete.rst | 25 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/future-directives/onSuccess.rst | 25 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/header-directives/headerValue.rst | 30 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/header-directives/headerValueByName.rst | 26 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/header-directives/headerValueByType.rst | 32 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/header-directives/headerValuePF.rst | 27 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/header-directives/index.rst | 19 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/header-directives/optionalHeaderValue.rst | 24 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/header-directives/optionalHeaderValueByName.rst | 23 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/header-directives/optionalHeaderValueByType.rst | 29 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/header-directives/optionalHeaderValuePF.rst | 24 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/host-directives/extractHost.rst | 23 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/host-directives/host.rst | 55 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/host-directives/index.rst | 13 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/index.rst | 227 ++++ | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/marshalling-directives/completeWith.rst | 45 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/marshalling-directives/entity.rst | 51 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/marshalling-directives/handleWith.rst | 47 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/marshalling-directives/index.rst | 34 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/method-directives/delete.rst | 27 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/method-directives/extractMethod.rst | 24 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/method-directives/get.rst | 26 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/method-directives/head.rst | 29 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/method-directives/index.rst | 18 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/method-directives/method.rst | 25 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/method-directives/options.rst | 25 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/method-directives/overrideMethodWithParameter.rst | 31 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/method-directives/patch.rst | 26 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/method-directives/post.rst | 26 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/method-directives/put.rst | 25 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/misc-directives/extractClientIP.rst | 24 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/misc-directives/index.rst | 14 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/misc-directives/rejectEmptyResponse.rst | 25 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/misc-directives/requestEntityEmpty.rst | 26 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/misc-directives/requestEntityPresent.rst | 25 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/misc-directives/selectPreferredLanguage.rst | 25 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/misc-directives/validate.rst | 23 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/parameter-directives/index.rst | 43 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/parameter-directives/parameter.rst | 24 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/parameter-directives/parameterMap.rst | 24 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/parameter-directives/parameterMultiMap.rst | 28 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/parameter-directives/parameterSeq.rst | 24 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/parameter-directives/parameters.rst | 107 ++ | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/path-directives/index.rst | 21 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/path-directives/path.rst | 39 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/path-directives/pathEnd.rst | 27 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/path-directives/pathEndOrSingleSlash.rst | 28 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/path-directives/pathPrefix.rst | 33 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/path-directives/pathPrefixTest.rst | 36 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/path-directives/pathSingleSlash.rst | 26 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/path-directives/pathSuffix.rst | 36 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/path-directives/pathSuffixTest.rst | 37 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/path-directives/rawPathPrefix.rst | 33 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/path-directives/rawPathPrefixTest.rst | 36 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/path-directives/redirectToNoTrailingSlashIfPresent.rst | 37 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/path-directives/redirectToTrailingSlashIfMissing.rst | 33 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/range-directives/index.rst | 9 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/range-directives/withRangeSupport.rst | 46 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/respond-with-directives/index.rst | 13 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/respond-with-directives/respondWithDefaultHeader.rst | 30 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/respond-with-directives/respondWithDefaultHeaders.rst | 43 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/respond-with-directives/respondWithHeader.rst | 26 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/respond-with-directives/respondWithHeaders.rst | 27 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/route-directives/complete.rst | 39 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/route-directives/failWith.rst | 36 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/route-directives/index.rst | 21 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/route-directives/redirect.rst | 28 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/route-directives/reject.rst | 31 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/scheme-directives/extractScheme.rst | 22 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/scheme-directives/index.rst | 13 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/scheme-directives/scheme.rst | 30 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/security-directives/authenticateBasic.rst | 41 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/security-directives/authenticateBasicAsync.rst | 39 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/security-directives/authenticateBasicPF.rst | 39 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/security-directives/authenticateBasicPFAsync.rst | 36 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/security-directives/authenticateOAuth2.rst | 42 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/security-directives/authenticateOAuth2Async.rst | 42 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/security-directives/authenticateOAuth2PF.rst | 43 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/security-directives/authenticateOAuth2PFAsync.rst | 44 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/security-directives/authenticateOrRejectWithChallenge.rst | 30 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/security-directives/authorize.rst | 35 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/security-directives/extractCredentials.rst | 24 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/security-directives/index.rst | 83 ++ | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/websocket-directives/handleWebsocketMessages.rst | 27 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/websocket-directives/handleWebsocketMessagesForProtocol.rst | 31 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/directives/websocket-directives/index.rst | 10 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/exception-handling.rst | 45 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/index.rst | 99 ++ | |
| akka-docs-dev/rst/scala/http/routing-dsl/overview.rst | 50 + | |
| akka-docs-dev/rst/scala/http/routing-dsl/path-matchers.rst | 196 +++ | |
| akka-docs-dev/rst/scala/http/routing-dsl/rejections.rst | 138 ++ | |
| akka-docs-dev/rst/scala/http/routing-dsl/routes.rst | 120 ++ | |
| akka-docs-dev/rst/scala/http/routing-dsl/testkit.rst | 107 ++ | |
| akka-docs-dev/rst/scala/http/routing-dsl/websocket-support.rst | 114 ++ | |
| akka-docs-dev/rst/scala/migration-guide-1.0-2.x-scala.rst | 739 +++++++++++ | |
| akka-docs-dev/rst/scala/stream-composition.rst | 311 +++++ | |
| akka-docs-dev/rst/scala/stream-cookbook.rst | 379 ++++++ | |
| akka-docs-dev/rst/scala/stream-customize.rst | 445 +++++++ | |
| akka-docs-dev/rst/scala/stream-error.rst | 79 ++ | |
| akka-docs-dev/rst/scala/stream-flows-and-basics.rst | 317 +++++ | |
| akka-docs-dev/rst/scala/stream-graphs.rst | 372 ++++++ | |
| akka-docs-dev/rst/scala/stream-index.rst | 25 + | |
| akka-docs-dev/rst/scala/stream-integrations.rst | 435 ++++++ | |
| akka-docs-dev/rst/scala/stream-introduction.rst | 85 ++ | |
| akka-docs-dev/rst/scala/stream-io.rst | 124 ++ | |
| akka-docs-dev/rst/scala/stream-parallelism.rst | 103 ++ | |
| akka-docs-dev/rst/scala/stream-quickstart.rst | 195 +++ | |
| akka-docs-dev/rst/scala/stream-rate.rst | 169 +++ | |
| akka-docs-dev/rst/scala/stream-testkit.rst | 118 ++ | |
| akka-docs-dev/rst/stages-overview.rst | 154 +++ | |
| akka-docs-dev/rst/stream-configuration.rst | 7 + | |
| akka-docs-dev/rst/stream-design.rst | 104 ++ | |
| akka-docs-dev/src/test/resources/application.conf | 1 + | |
| akka-http-core/RunWebsocketAutobahnTestSuite.md | 51 + | |
| akka-http-core/src/main/java/akka/http/impl/util/Util.java | 88 ++ | |
| akka-http-core/src/main/java/akka/http/javadsl/HttpsContext.java | 48 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/BodyPartEntity.java | 8 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/ContentRange.java | 38 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/ContentType.java | 41 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/ContentTypeRange.java | 20 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/ContentTypes.java | 38 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/DateTime.java | 124 ++ | |
| akka-http-core/src/main/java/akka/http/javadsl/model/FormData.java | 53 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/Host.java | 60 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/HttpCharset.java | 47 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/HttpCharsetRange.java | 27 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/HttpCharsetRanges.java | 17 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/HttpCharsets.java | 37 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/HttpEntities.java | 72 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/HttpEntity.java | 225 ++++ | |
| akka-http-core/src/main/java/akka/http/javadsl/model/HttpHeader.java | 37 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/HttpMessage.java | 114 ++ | |
| akka-http-core/src/main/java/akka/http/javadsl/model/HttpMethod.java | 38 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/HttpMethods.java | 40 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/HttpProtocol.java | 16 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/HttpProtocols.java | 15 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/HttpRequest.java | 110 ++ | |
| akka-http-core/src/main/java/akka/http/javadsl/model/HttpResponse.java | 44 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/MediaRange.java | 39 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/MediaRanges.java | 46 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/MediaType.java | 67 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/MediaTypes.java | 203 +++ | |
| akka-http-core/src/main/java/akka/http/javadsl/model/Multipart.java | 145 ++ | |
| akka-http-core/src/main/java/akka/http/javadsl/model/Query.java | 107 ++ | |
| akka-http-core/src/main/java/akka/http/javadsl/model/RemoteAddress.java | 35 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/RequestEntity.java | 8 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/ResponseEntity.java | 8 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/StatusCode.java | 48 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/StatusCodes.java | 115 ++ | |
| akka-http-core/src/main/java/akka/http/javadsl/model/TransferEncoding.java | 22 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/TransferEncodings.java | 14 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/UniversalEntity.java | 8 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/Uri.java | 180 +++ | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/Accept.java | 22 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/AcceptCharset.java | 20 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/AcceptEncoding.java | 22 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/AcceptLanguage.java | 17 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/AcceptRanges.java | 17 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/AccessControlAllowCredentials.java | 17 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/AccessControlAllowHeaders.java | 17 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/AccessControlAllowMethods.java | 19 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/AccessControlAllowOrigin.java | 17 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/AccessControlExposeHeaders.java | 17 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/AccessControlMaxAge.java | 17 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/AccessControlRequestHeaders.java | 17 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/AccessControlRequestMethod.java | 19 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/Age.java | 17 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/Allow.java | 19 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/Authorization.java | 23 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/BasicHttpCredentials.java | 10 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/ByteRange.java | 29 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/CacheControl.java | 17 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/CacheDirective.java | 9 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/CacheDirectives.java | 40 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/ContentDisposition.java | 18 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/ContentDispositionType.java | 9 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/ContentDispositionTypes.java | 17 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/ContentEncoding.java | 17 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/ContentRange.java | 18 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/ContentType.java | 17 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/Cookie.java | 20 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/CustomHeader.java | 12 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/Date.java | 19 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/ETag.java | 17 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/EntityTag.java | 20 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/EntityTagRange.java | 14 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/Expires.java | 19 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/Host.java | 25 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/HttpChallenge.java | 23 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/HttpCookie.java | 95 ++ | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/HttpCookiePair.java | 28 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/HttpCredentials.java | 29 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/HttpEncoding.java | 13 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/HttpEncodingRange.java | 19 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/HttpEncodings.java | 17 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/HttpOrigin.java | 19 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/HttpOriginRange.java | 17 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/IfMatch.java | 17 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/IfModifiedSince.java | 19 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/IfNoneMatch.java | 17 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/IfUnmodifiedSince.java | 19 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/Language.java | 18 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/LanguageRange.java | 15 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/LastModified.java | 19 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/Link.java | 17 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/LinkParam.java | 10 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/LinkParams.java | 43 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/LinkValue.java | 19 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/Location.java | 22 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/OAuth2BearerToken.java | 9 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/Origin.java | 17 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/ProductVersion.java | 18 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/ProxyAuthenticate.java | 17 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/ProxyAuthorization.java | 17 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/Range.java | 18 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/RangeUnit.java | 13 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/RangeUnits.java | 11 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/RawHeader.java | 14 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/RawRequestURI.java | 18 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/Referer.java | 19 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/RemoteAddress.java | 17 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/Server.java | 17 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/SetCookie.java | 17 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/TlsSessionInfo.java | 25 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/TransferEncoding.java | 17 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/UserAgent.java | 17 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/WWWAuthenticate.java | 17 + | |
| akka-http-core/src/main/java/akka/http/javadsl/model/headers/XForwardedFor.java | 17 + | |
| akka-http-core/src/main/resources/reference.conf | 346 +++++ | |
| akka-http-core/src/main/scala/akka/http/ClientConnectionSettings.scala | 71 + | |
| akka-http-core/src/main/scala/akka/http/ConnectionPoolSettings.scala | 81 ++ | |
| akka-http-core/src/main/scala/akka/http/ParserSettings.scala | 134 ++ | |
| akka-http-core/src/main/scala/akka/http/ServerSettings.scala | 105 ++ | |
| akka-http-core/src/main/scala/akka/http/impl/engine/HttpConnectionTimeoutException.scala | 9 + | |
| akka-http-core/src/main/scala/akka/http/impl/engine/TokenSourceActor.scala | 40 + | |
| akka-http-core/src/main/scala/akka/http/impl/engine/client/OutgoingConnectionBlueprint.scala | 235 ++++ | |
| akka-http-core/src/main/scala/akka/http/impl/engine/client/PoolConductor.scala | 229 ++++ | |
| akka-http-core/src/main/scala/akka/http/impl/engine/client/PoolFlow.scala | 92 ++ | |
| akka-http-core/src/main/scala/akka/http/impl/engine/client/PoolGateway.scala | 88 ++ | |
| akka-http-core/src/main/scala/akka/http/impl/engine/client/PoolInterfaceActor.scala | 166 +++ | |
| akka-http-core/src/main/scala/akka/http/impl/engine/client/PoolSlot.scala | 253 ++++ | |
| akka-http-core/src/main/scala/akka/http/impl/engine/parsing/BodyPartParser.scala | 301 +++++ | |
| akka-http-core/src/main/scala/akka/http/impl/engine/parsing/BoyerMoore.scala | 68 + | |
| akka-http-core/src/main/scala/akka/http/impl/engine/parsing/HttpHeaderParser.scala | 579 ++++++++ | |
| akka-http-core/src/main/scala/akka/http/impl/engine/parsing/HttpMessageParser.scala | 362 +++++ | |
| akka-http-core/src/main/scala/akka/http/impl/engine/parsing/HttpRequestParser.scala | 169 +++ | |
| akka-http-core/src/main/scala/akka/http/impl/engine/parsing/HttpResponseParser.scala | 140 ++ | |
| akka-http-core/src/main/scala/akka/http/impl/engine/parsing/ParserOutput.scala | 79 ++ | |
| akka-http-core/src/main/scala/akka/http/impl/engine/parsing/SpecializedHeaderValueParsers.scala | 34 + | |
| akka-http-core/src/main/scala/akka/http/impl/engine/parsing/package.scala | 67 + | |
| akka-http-core/src/main/scala/akka/http/impl/engine/rendering/BodyPartRenderer.scala | 126 ++ | |
| akka-http-core/src/main/scala/akka/http/impl/engine/rendering/HttpRequestRendererFactory.scala | 159 +++ | |
| akka-http-core/src/main/scala/akka/http/impl/engine/rendering/HttpResponseRendererFactory.scala | 274 ++++ | |
| akka-http-core/src/main/scala/akka/http/impl/engine/rendering/RenderSupport.scala | 118 ++ | |
| akka-http-core/src/main/scala/akka/http/impl/engine/server/HttpAttributes.scala | 24 + | |
| akka-http-core/src/main/scala/akka/http/impl/engine/server/HttpServerBluePrint.scala | 465 +++++++ | |
| akka-http-core/src/main/scala/akka/http/impl/engine/ws/FrameEvent.scala | 76 ++ | |
| akka-http-core/src/main/scala/akka/http/impl/engine/ws/FrameEventParser.scala | 141 ++ | |
| akka-http-core/src/main/scala/akka/http/impl/engine/ws/FrameEventRenderer.scala | 106 ++ | |
| akka-http-core/src/main/scala/akka/http/impl/engine/ws/FrameHandler.scala | 209 +++ | |
| akka-http-core/src/main/scala/akka/http/impl/engine/ws/FrameOutHandler.scala | 150 +++ | |
| akka-http-core/src/main/scala/akka/http/impl/engine/ws/Handshake.scala | 267 ++++ | |
| akka-http-core/src/main/scala/akka/http/impl/engine/ws/Masking.scala | 90 ++ | |
| akka-http-core/src/main/scala/akka/http/impl/engine/ws/MessageToFrameRenderer.scala | 37 + | |
| akka-http-core/src/main/scala/akka/http/impl/engine/ws/Protocol.scala | 84 ++ | |
| akka-http-core/src/main/scala/akka/http/impl/engine/ws/Randoms.scala | 15 + | |
| akka-http-core/src/main/scala/akka/http/impl/engine/ws/UpgradeToWebsocketLowLevel.scala | 28 + | |
| akka-http-core/src/main/scala/akka/http/impl/engine/ws/UpgradeToWebsocketsResponseHeader.scala | 18 + | |
| akka-http-core/src/main/scala/akka/http/impl/engine/ws/Utf8Decoder.scala | 118 ++ | |
| akka-http-core/src/main/scala/akka/http/impl/engine/ws/Utf8Encoder.scala | 80 ++ | |
| akka-http-core/src/main/scala/akka/http/impl/engine/ws/Websocket.scala | 235 ++++ | |
| akka-http-core/src/main/scala/akka/http/impl/engine/ws/WebsocketClientBlueprint.scala | 136 ++ | |
| akka-http-core/src/main/scala/akka/http/impl/model/JavaQuery.scala | 33 + | |
| akka-http-core/src/main/scala/akka/http/impl/model/JavaUri.scala | 76 ++ | |
| akka-http-core/src/main/scala/akka/http/impl/model/parser/AcceptCharsetHeader.scala | 30 + | |
| akka-http-core/src/main/scala/akka/http/impl/model/parser/AcceptEncodingHeader.scala | 30 + | |
| akka-http-core/src/main/scala/akka/http/impl/model/parser/AcceptHeader.scala | 39 + | |
| akka-http-core/src/main/scala/akka/http/impl/model/parser/AcceptLanguageHeader.scala | 27 + | |
| akka-http-core/src/main/scala/akka/http/impl/model/parser/Base64Parsing.scala | 80 ++ | |
| akka-http-core/src/main/scala/akka/http/impl/model/parser/CacheControlHeader.scala | 40 + | |
| akka-http-core/src/main/scala/akka/http/impl/model/parser/CharacterClasses.scala | 88 ++ | |
| akka-http-core/src/main/scala/akka/http/impl/model/parser/CommonActions.scala | 45 + | |
| akka-http-core/src/main/scala/akka/http/impl/model/parser/CommonRules.scala | 445 +++++++ | |
| akka-http-core/src/main/scala/akka/http/impl/model/parser/ContentDispositionHeader.scala | 40 + | |
| akka-http-core/src/main/scala/akka/http/impl/model/parser/ContentTypeHeader.scala | 43 + | |
| akka-http-core/src/main/scala/akka/http/impl/model/parser/HeaderParser.scala | 174 +++ | |
| akka-http-core/src/main/scala/akka/http/impl/model/parser/IpAddressParsing.scala | 63 + | |
| akka-http-core/src/main/scala/akka/http/impl/model/parser/LinkHeader.scala | 80 ++ | |
| akka-http-core/src/main/scala/akka/http/impl/model/parser/SimpleHeaders.scala | 224 ++++ | |
| akka-http-core/src/main/scala/akka/http/impl/model/parser/StringBuilding.scala | 67 + | |
| akka-http-core/src/main/scala/akka/http/impl/model/parser/UriParser.scala | 239 ++++ | |
| akka-http-core/src/main/scala/akka/http/impl/model/parser/WebsocketHeaders.scala | 61 + | |
| akka-http-core/src/main/scala/akka/http/impl/util/ByteReader.scala | 51 + | |
| akka-http-core/src/main/scala/akka/http/impl/util/ByteStringParserStage.scala | 59 + | |
| akka-http-core/src/main/scala/akka/http/impl/util/EnhancedByteArray.scala | 31 + | |
| akka-http-core/src/main/scala/akka/http/impl/util/EnhancedByteStringTraversableOnce.scala | 14 + | |
| akka-http-core/src/main/scala/akka/http/impl/util/EnhancedConfig.scala | 46 + | |
| akka-http-core/src/main/scala/akka/http/impl/util/EnhancedInetSocketAddress.scala | 60 + | |
| akka-http-core/src/main/scala/akka/http/impl/util/EnhancedRegex.scala | 14 + | |
| akka-http-core/src/main/scala/akka/http/impl/util/EnhancedString.scala | 121 ++ | |
| akka-http-core/src/main/scala/akka/http/impl/util/Java6Compat.scala | 60 + | |
| akka-http-core/src/main/scala/akka/http/impl/util/JavaAccessors.scala | 31 + | |
| akka-http-core/src/main/scala/akka/http/impl/util/JavaMapping.scala | 228 ++++ | |
| akka-http-core/src/main/scala/akka/http/impl/util/ObjectRegistry.scala | 25 + | |
| akka-http-core/src/main/scala/akka/http/impl/util/Rendering.scala | 359 +++++ | |
| akka-http-core/src/main/scala/akka/http/impl/util/SettingsCompanion.scala | 56 + | |
| akka-http-core/src/main/scala/akka/http/impl/util/SingletonException.scala | 16 + | |
| akka-http-core/src/main/scala/akka/http/impl/util/SocketOptionSettings.scala | 30 + | |
| akka-http-core/src/main/scala/akka/http/impl/util/StreamUtils.scala | 314 +++++ | |
| akka-http-core/src/main/scala/akka/http/impl/util/Timestamp.scala | 42 + | |
| akka-http-core/src/main/scala/akka/http/impl/util/package.scala | 183 +++ | |
| akka-http-core/src/main/scala/akka/http/javadsl/HostConnectionPool.scala | 11 + | |
| akka-http-core/src/main/scala/akka/http/javadsl/Http.scala | 646 +++++++++ | |
| akka-http-core/src/main/scala/akka/http/javadsl/IncomingConnection.scala | 60 + | |
| akka-http-core/src/main/scala/akka/http/javadsl/OutgoingConnection.scala | 21 + | |
| akka-http-core/src/main/scala/akka/http/javadsl/ServerBinding.scala | 26 + | |
| akka-http-core/src/main/scala/akka/http/javadsl/model/ws/Message.scala | 148 +++ | |
| akka-http-core/src/main/scala/akka/http/javadsl/model/ws/PeerClosedConnectionException.scala | 14 + | |
| akka-http-core/src/main/scala/akka/http/javadsl/model/ws/UpgradeToWebsocket.scala | 51 + | |
| akka-http-core/src/main/scala/akka/http/javadsl/model/ws/Websocket.scala | 22 + | |
| akka-http-core/src/main/scala/akka/http/javadsl/model/ws/WebsocketRequest.scala | 61 + | |
| akka-http-core/src/main/scala/akka/http/javadsl/model/ws/WebsocketUpgradeResponse.scala | 58 + | |
| akka-http-core/src/main/scala/akka/http/scaladsl/Http.scala | 783 +++++++++++ | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/ContentRange.scala | 77 ++ | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/ContentType.scala | 112 ++ | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/DateTime.scala | 263 ++++ | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/ErrorInfo.scala | 90 ++ | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/FormData.scala | 32 + | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/HttpCharset.scala | 131 ++ | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/HttpEntity.scala | 503 +++++++ | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/HttpHeader.scala | 97 ++ | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/HttpMessage.scala | 272 ++++ | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/HttpMethod.scala | 70 + | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/HttpProtocol.scala | 18 + | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/MediaRange.scala | 148 +++ | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/MediaType.scala | 480 +++++++ | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/Multipart.scala | 574 ++++++++ | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/RemoteAddress.scala | 58 + | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/StatusCode.scala | 172 +++ | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/TransferEncoding.scala | 35 + | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/Uri.scala | 889 +++++++++++++ | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/WithQValue.scala | 12 + | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/headers/ByteRange.scala | 68 + | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/headers/CacheDirective.scala | 113 ++ | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/headers/ContentDispositionType.scala | 23 + | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/headers/EntityTag.scala | 40 + | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/headers/HttpChallenge.scala | 23 + | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/headers/HttpCookie.scala | 132 ++ | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/headers/HttpCredentials.scala | 74 ++ | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/headers/HttpEncoding.scala | 64 + | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/headers/HttpOrigin.scala | 46 + | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/headers/LanguageRange.scala | 76 ++ | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/headers/LinkValue.scala | 116 ++ | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/headers/ProductVersion.scala | 39 + | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/headers/RangeUnit.scala | 24 + | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/headers/UpgradeProtocol.scala | 15 + | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/headers/WebsocketExtension.scala | 23 + | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/headers/headers.scala | 871 ++++++++++++ | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/package.scala | 10 + | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/ws/Message.scala | 61 + | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/ws/PeerClosedConnectionException.scala | 14 + | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/ws/UpgradeToWebsocket.scala | 92 ++ | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/ws/WebsocketRequest.scala | 26 + | |
| akka-http-core/src/main/scala/akka/http/scaladsl/model/ws/WebsocketUpgradeResponse.scala | 16 + | |
| akka-http-core/src/main/scala/akka/http/scaladsl/util/FastFuture.scala | 114 ++ | |
| akka-http-core/src/test/java/akka/http/javadsl/WSEchoTestClientApp.java | 83 ++ | |
| akka-http-core/src/test/java/akka/http/javadsl/model/JavaApiTestCases.java | 70 + | |
| akka-http-core/src/test/java/akka/http/javadsl/model/JavaTestServer.java | 82 ++ | |
| akka-http-core/src/test/resources/keys/README.md | 57 + | |
| akka-http-core/src/test/resources/keys/chain.pem | 40 + | |
| akka-http-core/src/test/resources/keys/rootCA.crt | 21 + | |
| akka-http-core/src/test/resources/keys/rootCA.key | 27 + | |
| akka-http-core/src/test/resources/keys/server.crt | 19 + | |
| akka-http-core/src/test/resources/keys/server.key | 27 + | |
| akka-http-core/src/test/resources/keys/server.p12 | Bin 0 -> 3384 bytes | |
| akka-http-core/src/test/resources/reference.conf | 9 + | |
| akka-http-core/src/test/scala/akka/http/impl/engine/client/ClientCancellationSpec.scala | 74 ++ | |
| akka-http-core/src/test/scala/akka/http/impl/engine/client/ConnectionPoolSpec.scala | 369 ++++++ | |
| akka-http-core/src/test/scala/akka/http/impl/engine/client/HighLevelOutgoingConnectionSpec.scala | 86 ++ | |
| akka-http-core/src/test/scala/akka/http/impl/engine/client/HttpConfigurationSpec.scala | 141 ++ | |
| akka-http-core/src/test/scala/akka/http/impl/engine/client/LowLevelOutgoingConnectionSpec.scala | 585 ++++++++ | |
| akka-http-core/src/test/scala/akka/http/impl/engine/client/TlsEndpointVerificationSpec.scala | 121 ++ | |
| akka-http-core/src/test/scala/akka/http/impl/engine/parsing/BoyerMooreSpec.scala | 80 ++ | |
| akka-http-core/src/test/scala/akka/http/impl/engine/parsing/ContentLengthHeaderParserSpec.scala | 37 + | |
| akka-http-core/src/test/scala/akka/http/impl/engine/parsing/HttpHeaderParserSpec.scala | 278 ++++ | |
| akka-http-core/src/test/scala/akka/http/impl/engine/parsing/HttpHeaderParserTestBed.scala | 34 + | |
| akka-http-core/src/test/scala/akka/http/impl/engine/parsing/RequestParserSpec.scala | 525 ++++++++ | |
| akka-http-core/src/test/scala/akka/http/impl/engine/parsing/ResponseParserSpec.scala | 333 +++++ | |
| akka-http-core/src/test/scala/akka/http/impl/engine/rendering/RequestRendererSpec.scala | 332 +++++ | |
| akka-http-core/src/test/scala/akka/http/impl/engine/rendering/ResponseRendererSpec.scala | 614 +++++++++ | |
| akka-http-core/src/test/scala/akka/http/impl/engine/server/HttpServerSpec.scala | 915 +++++++++++++ | |
| akka-http-core/src/test/scala/akka/http/impl/engine/server/HttpServerTestSetupBase.scala | 75 ++ | |
| akka-http-core/src/test/scala/akka/http/impl/engine/ws/BitBuilder.scala | 102 ++ | |
| akka-http-core/src/test/scala/akka/http/impl/engine/ws/ByteStringSinkProbe.scala | 73 + | |
| akka-http-core/src/test/scala/akka/http/impl/engine/ws/EchoTestClientApp.scala | 68 + | |
| akka-http-core/src/test/scala/akka/http/impl/engine/ws/FramingSpec.scala | 321 +++++ | |
| akka-http-core/src/test/scala/akka/http/impl/engine/ws/MessageSpec.scala | 977 ++++++++++++++ | |
| akka-http-core/src/test/scala/akka/http/impl/engine/ws/Utf8CodingSpecs.scala | 60 + | |
| akka-http-core/src/test/scala/akka/http/impl/engine/ws/WSClientAutobahnTest.scala | 227 ++++ | |
| akka-http-core/src/test/scala/akka/http/impl/engine/ws/WSServerAutobahnTest.scala | 52 + | |
| akka-http-core/src/test/scala/akka/http/impl/engine/ws/WSTestSetupBase.scala | 111 ++ | |
| akka-http-core/src/test/scala/akka/http/impl/engine/ws/WSTestUtils.scala | 82 ++ | |
| akka-http-core/src/test/scala/akka/http/impl/engine/ws/WebsocketClientSpec.scala | 375 ++++++ | |
| akka-http-core/src/test/scala/akka/http/impl/engine/ws/WebsocketServerSpec.scala | 135 ++ | |
| akka-http-core/src/test/scala/akka/http/impl/engine/ws/WithMaterializerSpec.scala | 20 + | |
| akka-http-core/src/test/scala/akka/http/impl/model/parser/HttpHeaderSpec.scala | 666 ++++++++++ | |
| akka-http-core/src/test/scala/akka/http/impl/util/EnhancedInetSocketAddressSpec.scala | 34 + | |
| akka-http-core/src/test/scala/akka/http/impl/util/ExampleHttpContexts.scala | 58 + | |
| akka-http-core/src/test/scala/akka/http/impl/util/RenderingSpec.scala | 37 + | |
| akka-http-core/src/test/scala/akka/http/javadsl/model/JavaApiSpec.scala | 63 + | |
| akka-http-core/src/test/scala/akka/http/javadsl/model/JavaApiTestCaseSpecs.scala | 70 + | |
| akka-http-core/src/test/scala/akka/http/scaladsl/ClientServerSpec.scala | 523 ++++++++ | |
| akka-http-core/src/test/scala/akka/http/scaladsl/TestClient.scala | 66 + | |
| akka-http-core/src/test/scala/akka/http/scaladsl/TestServer.scala | 77 ++ | |
| akka-http-core/src/test/scala/akka/http/scaladsl/TestUtils.scala | 24 + | |
| akka-http-core/src/test/scala/akka/http/scaladsl/model/DateTimeSpec.scala | 98 ++ | |
| akka-http-core/src/test/scala/akka/http/scaladsl/model/HttpEntitySpec.scala | 185 +++ | |
| akka-http-core/src/test/scala/akka/http/scaladsl/model/HttpMessageSpec.scala | 28 + | |
| akka-http-core/src/test/scala/akka/http/scaladsl/model/MultipartSpec.scala | 66 + | |
| akka-http-core/src/test/scala/akka/http/scaladsl/model/SerializabilitySpec.scala | 91 ++ | |
| akka-http-core/src/test/scala/akka/http/scaladsl/model/TurkishISpec.scala | 34 + | |
| akka-http-core/src/test/scala/akka/http/scaladsl/model/UriSpec.scala | 619 +++++++++ | |
| akka-http-core/src/test/scala/akka/http/scaladsl/model/headers/HeaderSpec.scala | 64 + | |
| akka-http-core/src/test/scala/akka/http/scaladsl/util/FastFutureSpec.scala | 183 +++ | |
| akka-http-core/src/test/scala/io/akka/integrationtest/http/HttpModelIntegrationSpec.scala | 214 +++ | |
| akka-http-core/src/test/scripts/autobahn-jenkins/step-1-client-tests.sh | 22 + | |
| akka-http-core/src/test/scripts/autobahn-jenkins/step-2-run-sbt-client.sh | 3 + | |
| akka-http-core/src/test/scripts/autobahn-jenkins/step-3-download-client-test-results.sh | 13 + | |
| akka-http-core/src/test/scripts/autobahn-jenkins/step-4-stop-client-tests-server.sh | 4 + | |
| akka-http-core/src/test/scripts/autobahn-jenkins/step-5-server-tests-all.sh | 67 + | |
| akka-http-core/src/test/scripts/autobahn-jenkins/step-6-collect-results.sh | 37 + | |
| akka-http-marshallers-java/akka-http-jackson/src/main/scala/akka/http/javadsl/marshallers/jackson/Jackson.scala | 39 + | |
| akka-http-marshallers-scala/akka-http-spray-json/src/main/scala/akka/http/scaladsl/marshallers/sprayjson/SprayJsonSupport.scala | 37 + | |
| akka-http-marshallers-scala/akka-http-xml/src/main/scala/akka/http/scaladsl/marshallers/xml/ScalaXmlSupport.scala | 62 + | |
| akka-http-testkit/src/main/scala/akka/http/javadsl/testkit/DefaultHostInfo.scala | 14 + | |
| akka-http-testkit/src/main/scala/akka/http/javadsl/testkit/JUnitRouteTest.scala | 74 ++ | |
| akka-http-testkit/src/main/scala/akka/http/javadsl/testkit/RouteTest.scala | 83 ++ | |
| akka-http-testkit/src/main/scala/akka/http/javadsl/testkit/TestResponse.scala | 178 +++ | |
| akka-http-testkit/src/main/scala/akka/http/javadsl/testkit/TestRoute.scala | 21 + | |
| akka-http-testkit/src/main/scala/akka/http/scaladsl/testkit/MarshallingTestUtils.scala | 29 + | |
| akka-http-testkit/src/main/scala/akka/http/scaladsl/testkit/RouteTest.scala | 163 +++ | |
| akka-http-testkit/src/main/scala/akka/http/scaladsl/testkit/RouteTestResultComponent.scala | 100 ++ | |
| akka-http-testkit/src/main/scala/akka/http/scaladsl/testkit/RouteTestTimeout.scala | 15 + | |
| akka-http-testkit/src/main/scala/akka/http/scaladsl/testkit/ScalatestUtils.scala | 31 + | |
| akka-http-testkit/src/main/scala/akka/http/scaladsl/testkit/TestFrameworkInterface.scala | 32 + | |
| akka-http-testkit/src/main/scala/akka/http/scaladsl/testkit/WSProbe.scala | 142 ++ | |
| akka-http-testkit/src/main/scala/akka/http/scaladsl/testkit/WSTestRequestBuilding.scala | 29 + | |
| akka-http-testkit/src/test/scala/akka/http/scaladsl/testkit/ScalatestRouteTestSpec.scala | 81 ++ | |
| akka-http-tests-java8/src/main/java/akka/http/javadsl/server/examples/simple/SimpleServerApp8.java | 99 ++ | |
| akka-http-tests-java8/src/main/resources/web/calculator.html | 23 + | |
| akka-http-tests-java8/src/test/java/AllJavaTests.java | 16 + | |
| akka-http-tests-java8/src/test/java/akka/http/javadsl/server/HandlerBindingTest.java | 83 ++ | |
| akka-http-tests-java8/src/test/java/docs/http/javadsl/server/HandlerExampleDocTest.java | 312 +++++ | |
| akka-http-tests-java8/src/test/resources/reference.conf | 6 + | |
| "akka-http-tests/lib/i have sp\303\244ces.jar" | Bin 0 -> 488 bytes | |
| akka-http-tests/src/main/java/akka/http/javadsl/server/examples/petstore/Pet.java | 30 + | |
| akka-http-tests/src/main/java/akka/http/javadsl/server/examples/petstore/PetStoreController.java | 22 + | |
| akka-http-tests/src/main/java/akka/http/javadsl/server/examples/petstore/PetStoreExample.java | 71 + | |
| akka-http-tests/src/main/java/akka/http/javadsl/server/examples/simple/SimpleServerApp.java | 101 ++ | |
| akka-http-tests/src/main/resources/web/calculator.html | 23 + | |
| akka-http-tests/src/test/java/akka/http/javadsl/server/CompleteTest.java | 70 + | |
| akka-http-tests/src/test/java/akka/http/javadsl/server/HandlerBindingTest.java | 149 +++ | |
| akka-http-tests/src/test/java/akka/http/javadsl/server/MarshallerTest.java | 208 +++ | |
| akka-http-tests/src/test/java/akka/http/javadsl/server/directives/CodingDirectivesTest.java | 139 ++ | |
| akka-http-tests/src/test/java/akka/http/javadsl/server/directives/ExecutionDirectivesTest.java | 152 +++ | |
| akka-http-tests/src/test/java/akka/http/javadsl/server/directives/HostDirectivesTest.java | 72 + | |
| akka-http-tests/src/test/java/akka/http/javadsl/server/directives/MiscDirectivesTest.java | 117 ++ | |
| akka-http-tests/src/test/java/akka/http/javadsl/server/directives/PathDirectivesTest.java | 365 +++++ | |
| akka-http-tests/src/test/java/akka/http/javadsl/server/directives/RouteDirectivesTest.java | 98 ++ | |
| akka-http-tests/src/test/java/akka/http/javadsl/server/directives/SchemeDirectivesTest.java | 28 + | |
| akka-http-tests/src/test/java/akka/http/javadsl/server/examples/petstore/PetStoreAPITest.java | 79 ++ | |
| akka-http-tests/src/test/java/akka/http/javadsl/server/examples/simple/SimpleServerTest.java | 40 + | |
| akka-http-tests/src/test/java/akka/http/javadsl/server/values/CookiesTest.java | 71 + | |
| akka-http-tests/src/test/java/akka/http/javadsl/server/values/FormFieldsTest.java | 324 +++++ | |
| akka-http-tests/src/test/java/akka/http/javadsl/server/values/HeadersTest.java | 136 ++ | |
| akka-http-tests/src/test/java/akka/http/javadsl/server/values/HttpBasicAuthenticationTest.java | 110 ++ | |
| akka-http-tests/src/test/java/akka/http/javadsl/server/values/ParametersTest.java | 411 ++++++ | |
| akka-http-tests/src/test/java/akka/http/javadsl/server/values/RequestValTest.java | 102 ++ | |
| akka-http-tests/src/test/resources/reference.conf | 9 + | |
| akka-http-tests/src/test/resources/sample.html | 1 + | |
| akka-http-tests/src/test/resources/sample.xyz | 1 + | |
| akka-http-tests/src/test/resources/someDir/fileA.txt | 1 + | |
| akka-http-tests/src/test/resources/someDir/fileB.xml | 0 | |
| akka-http-tests/src/test/resources/someDir/sub/file.html | 0 | |
| akka-http-tests/src/test/resources/subDirectory/empty.pdf | 1 + | |
| akka-http-tests/src/test/resources/subDirectory/fileA.txt | 0 | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/FormDataSpec.scala | 42 + | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/Main.scala | 5 + | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/TestUtils.scala | 34 + | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/coding/CodecSpecSupport.scala | 79 ++ | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/coding/CoderSpec.scala | 190 +++ | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/coding/DecoderSpec.scala | 43 + | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/coding/DeflateSpec.scala | 28 + | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/coding/EncoderSpec.scala | 47 + | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/coding/GzipSpec.scala | 45 + | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/coding/NoCodingSpec.scala | 16 + | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/marshallers/JsonSupportSpec.scala | 70 + | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/marshallers/sprayjson/SprayJsonSupportSpec.scala | 29 + | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/marshallers/xml/ScalaXmlSupportSpec.scala | 104 ++ | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/marshalling/ContentNegotiationSpec.scala | 180 +++ | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/marshalling/MarshallingSpec.scala | 149 +++ | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/server/BasicRouteSpecs.scala | 192 +++ | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/server/ConnectionTestApp.scala | 98 ++ | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/server/DontLeakActorsOnFailingConnectionSpecs.scala | 102 ++ | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/server/ModeledCustomHeaderSpec.scala | 113 ++ | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/server/RoutingSpec.scala | 19 + | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/server/StreamingResponseSpecs.scala | 29 + | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/server/TcpLeakApp.scala | 47 + | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/server/TestServer.scala | 68 + | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/server/directives/BasicDirectivesSpec.scala | 29 + | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/server/directives/CacheConditionDirectivesSpec.scala | 184 +++ | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/server/directives/CodingDirectivesSpec.scala | 479 +++++++ | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/server/directives/CookieDirectivesSpec.scala | 95 ++ | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/server/directives/DebuggingDirectivesSpec.scala | 77 ++ | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/server/directives/ExecutionDirectivesSpec.scala | 104 ++ | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/server/directives/FileAndResourceDirectivesSpec.scala | 403 ++++++ | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/server/directives/FileUploadDirectivesSpec.scala | 153 +++ | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/server/directives/FormFieldDirectivesSpec.scala | 165 +++ | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/server/directives/FutureDirectivesSpec.scala | 106 ++ | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/server/directives/HeaderDirectivesSpec.scala | 162 +++ | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/server/directives/HostDirectivesSpec.scala | 55 + | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/server/directives/MarshallingDirectivesSpec.scala | 176 +++ | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/server/directives/MethodDirectivesSpec.scala | 89 ++ | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/server/directives/MiscDirectivesSpec.scala | 88 ++ | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/server/directives/ParameterDirectivesSpec.scala | 244 ++++ | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/server/directives/PathDirectivesSpec.scala | 367 +++++ | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/server/directives/RangeDirectivesSpec.scala | 139 ++ | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/server/directives/RespondWithDirectivesSpec.scala | 65 + | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/server/directives/RouteDirectivesSpec.scala | 150 +++ | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/server/directives/SchemeDirectivesSpec.scala | 41 + | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/server/directives/SecurityDirectivesSpec.scala | 139 ++ | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/server/directives/WebsocketDirectivesSpec.scala | 103 ++ | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/server/util/TupleOpsSpec.scala | 29 + | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/unmarshalling/MultipartUnmarshallersSpec.scala | 314 +++++ | |
| akka-http-tests/src/test/scala/akka/http/scaladsl/unmarshalling/UnmarshallingSpec.scala | 27 + | |
| akka-http/src/main/boilerplate/akka/http/javadsl/server/Handlers.scala.template | 37 + | |
| akka-http/src/main/boilerplate/akka/http/javadsl/server/directives/BasicDirectivesBase.scala.template | 61 + | |
| akka-http/src/main/boilerplate/akka/http/scaladsl/server/util/ApplyConverterInstances.scala.template | 17 + | |
| akka-http/src/main/boilerplate/akka/http/scaladsl/server/util/ConstructFromTupleInstances.scala.template | 13 + | |
| akka-http/src/main/boilerplate/akka/http/scaladsl/server/util/TupleAppendOneInstances.scala.template | 24 + | |
| akka-http/src/main/boilerplate/akka/http/scaladsl/server/util/TupleFoldInstances.scala.template | 33 + | |
| akka-http/src/main/java/akka/http/javadsl/server/AbstractDirective.java | 24 + | |
| akka-http/src/main/java/akka/http/javadsl/server/Coder.java | 35 + | |
| akka-http/src/main/java/akka/http/javadsl/server/Directive.java | 24 + | |
| akka-http/src/main/resources/reference.conf | 43 + | |
| akka-http/src/main/scala/akka/http/impl/server/CookieImpl.scala | 32 + | |
| akka-http/src/main/scala/akka/http/impl/server/CustomRejectionWrapper.scala | 15 + | |
| akka-http/src/main/scala/akka/http/impl/server/ExtractionImpl.scala | 23 + | |
| akka-http/src/main/scala/akka/http/impl/server/FormFieldImpl.scala | 51 + | |
| akka-http/src/main/scala/akka/http/impl/server/HeaderImpl.scala | 57 + | |
| akka-http/src/main/scala/akka/http/impl/server/MarshallerImpl.scala | 15 + | |
| akka-http/src/main/scala/akka/http/impl/server/ParameterImpl.scala | 49 + | |
| akka-http/src/main/scala/akka/http/impl/server/PathMatcherImpl.scala | 19 + | |
| akka-http/src/main/scala/akka/http/impl/server/RejectionHandlerWrapper.scala | 80 ++ | |
| akka-http/src/main/scala/akka/http/impl/server/RequestContextImpl.scala | 53 + | |
| akka-http/src/main/scala/akka/http/impl/server/RouteImplementation.scala | 227 ++++ | |
| akka-http/src/main/scala/akka/http/impl/server/RouteResultImpl.scala | 30 + | |
| akka-http/src/main/scala/akka/http/impl/server/RouteStructure.scala | 96 ++ | |
| akka-http/src/main/scala/akka/http/impl/server/StandaloneExtractionImpl.scala | 32 + | |
| akka-http/src/main/scala/akka/http/impl/server/UnmarshallerImpl.scala | 16 + | |
| akka-http/src/main/scala/akka/http/impl/server/Util.scala | 30 + | |
| akka-http/src/main/scala/akka/http/javadsl/server/CustomRejection.scala | 10 + | |
| akka-http/src/main/scala/akka/http/javadsl/server/CustomRequestVal.scala | 20 + | |
| akka-http/src/main/scala/akka/http/javadsl/server/Directives.scala | 25 + | |
| akka-http/src/main/scala/akka/http/javadsl/server/ExceptionHandler.scala | 9 + | |
| akka-http/src/main/scala/akka/http/javadsl/server/Handler.scala | 33 + | |
| akka-http/src/main/scala/akka/http/javadsl/server/HttpApp.scala | 27 + | |
| akka-http/src/main/scala/akka/http/javadsl/server/HttpService.scala | 47 + | |
| akka-http/src/main/scala/akka/http/javadsl/server/Marshaller.scala | 11 + | |
| akka-http/src/main/scala/akka/http/javadsl/server/Marshallers.scala | 69 + | |
| akka-http/src/main/scala/akka/http/javadsl/server/RejectionHandler.scala | 190 +++ | |
| akka-http/src/main/scala/akka/http/javadsl/server/RequestContext.scala | 78 ++ | |
| akka-http/src/main/scala/akka/http/javadsl/server/RequestVal.scala | 28 + | |
| akka-http/src/main/scala/akka/http/javadsl/server/RequestVals.scala | 112 ++ | |
| akka-http/src/main/scala/akka/http/javadsl/server/Route.scala | 14 + | |
| akka-http/src/main/scala/akka/http/javadsl/server/RouteResult.scala | 11 + | |
| akka-http/src/main/scala/akka/http/javadsl/server/Unmarshaller.scala | 14 + | |
| akka-http/src/main/scala/akka/http/javadsl/server/Unmarshallers.scala | 31 + | |
| akka-http/src/main/scala/akka/http/javadsl/server/directives/BasicDirectives.scala | 195 +++ | |
| akka-http/src/main/scala/akka/http/javadsl/server/directives/CacheConditionDirectives.scala | 59 + | |
| akka-http/src/main/scala/akka/http/javadsl/server/directives/CodingDirectives.scala | 74 ++ | |
| akka-http/src/main/scala/akka/http/javadsl/server/directives/CookieDirectives.scala | 19 + | |
| akka-http/src/main/scala/akka/http/javadsl/server/directives/ExecutionDirectives.scala | 41 + | |
| akka-http/src/main/scala/akka/http/javadsl/server/directives/FileAndResourceDirectives.scala | 128 ++ | |
| akka-http/src/main/scala/akka/http/javadsl/server/directives/HostDirectives.scala | 38 + | |
| akka-http/src/main/scala/akka/http/javadsl/server/directives/MethodDirectives.scala | 45 + | |
| akka-http/src/main/scala/akka/http/javadsl/server/directives/MiscDirectives.scala | 47 + | |
| akka-http/src/main/scala/akka/http/javadsl/server/directives/PathDirectives.scala | 187 +++ | |
| akka-http/src/main/scala/akka/http/javadsl/server/directives/RangeDirectives.scala | 28 + | |
| akka-http/src/main/scala/akka/http/javadsl/server/directives/SchemeDirectives.scala | 18 + | |
| akka-http/src/main/scala/akka/http/javadsl/server/directives/WebsocketDirectives.scala | 19 + | |
| akka-http/src/main/scala/akka/http/javadsl/server/values/Cookie.scala | 33 + | |
| akka-http/src/main/scala/akka/http/javadsl/server/values/FormField.scala | 44 + | |
| akka-http/src/main/scala/akka/http/javadsl/server/values/Header.scala | 37 + | |
| akka-http/src/main/scala/akka/http/javadsl/server/values/HttpBasicAuthenticator.scala | 59 + | |
| akka-http/src/main/scala/akka/http/javadsl/server/values/OAuth2Authenticator.scala | 59 + | |
| akka-http/src/main/scala/akka/http/javadsl/server/values/Parameter.scala | 69 + | |
| akka-http/src/main/scala/akka/http/javadsl/server/values/PathMatchers.scala | 135 ++ | |
| akka-http/src/main/scala/akka/http/scaladsl/client/RequestBuilding.scala | 99 ++ | |
| akka-http/src/main/scala/akka/http/scaladsl/client/TransformerPipelineSupport.scala | 49 + | |
| akka-http/src/main/scala/akka/http/scaladsl/coding/Coder.scala | 8 + | |
| akka-http/src/main/scala/akka/http/scaladsl/coding/DataMapper.scala | 35 + | |
| akka-http/src/main/scala/akka/http/scaladsl/coding/Decoder.scala | 54 + | |
| akka-http/src/main/scala/akka/http/scaladsl/coding/Deflate.scala | 175 +++ | |
| akka-http/src/main/scala/akka/http/scaladsl/coding/Encoder.scala | 79 ++ | |
| akka-http/src/main/scala/akka/http/scaladsl/coding/Gzip.scala | 145 ++ | |
| akka-http/src/main/scala/akka/http/scaladsl/coding/NoCoding.scala | 39 + | |
| akka-http/src/main/scala/akka/http/scaladsl/common/NameReceptacle.scala | 45 + | |
| akka-http/src/main/scala/akka/http/scaladsl/common/StrictForm.scala | 140 ++ | |
| akka-http/src/main/scala/akka/http/scaladsl/marshalling/ContentTypeOverrider.scala | 38 + | |
| akka-http/src/main/scala/akka/http/scaladsl/marshalling/EmptyValue.scala | 21 + | |
| akka-http/src/main/scala/akka/http/scaladsl/marshalling/GenericMarshallers.scala | 44 + | |
| akka-http/src/main/scala/akka/http/scaladsl/marshalling/Marshal.scala | 66 + | |
| akka-http/src/main/scala/akka/http/scaladsl/marshalling/Marshaller.scala | 175 +++ | |
| akka-http/src/main/scala/akka/http/scaladsl/marshalling/MultipartMarshallers.scala | 41 + | |
| akka-http/src/main/scala/akka/http/scaladsl/marshalling/PredefinedToEntityMarshallers.scala | 52 + | |
| akka-http/src/main/scala/akka/http/scaladsl/marshalling/PredefinedToRequestMarshallers.scala | 28 + | |
| akka-http/src/main/scala/akka/http/scaladsl/marshalling/PredefinedToResponseMarshallers.scala | 48 + | |
| akka-http/src/main/scala/akka/http/scaladsl/marshalling/ToResponseMarshallable.scala | 30 + | |
| akka-http/src/main/scala/akka/http/scaladsl/marshalling/package.scala | 17 + | |
| akka-http/src/main/scala/akka/http/scaladsl/server/ContentNegotation.scala | 264 ++++ | |
| akka-http/src/main/scala/akka/http/scaladsl/server/Directive.scala | 179 +++ | |
| akka-http/src/main/scala/akka/http/scaladsl/server/Directives.scala | 34 + | |
| akka-http/src/main/scala/akka/http/scaladsl/server/ExceptionHandler.scala | 58 + | |
| akka-http/src/main/scala/akka/http/scaladsl/server/PathMatcher.scala | 480 +++++++ | |
| akka-http/src/main/scala/akka/http/scaladsl/server/Rejection.scala | 210 +++ | |
| akka-http/src/main/scala/akka/http/scaladsl/server/RejectionHandler.scala | 229 ++++ | |
| akka-http/src/main/scala/akka/http/scaladsl/server/RequestContext.scala | 115 ++ | |
| akka-http/src/main/scala/akka/http/scaladsl/server/RequestContextImpl.scala | 91 ++ | |
| akka-http/src/main/scala/akka/http/scaladsl/server/Route.scala | 71 + | |
| akka-http/src/main/scala/akka/http/scaladsl/server/RouteConcatenation.scala | 35 + | |
| akka-http/src/main/scala/akka/http/scaladsl/server/RouteResult.scala | 32 + | |
| akka-http/src/main/scala/akka/http/scaladsl/server/RoutingLog.scala | 27 + | |
| akka-http/src/main/scala/akka/http/scaladsl/server/RoutingSettings.scala | 32 + | |
| akka-http/src/main/scala/akka/http/scaladsl/server/StandardRoute.scala | 28 + | |
| akka-http/src/main/scala/akka/http/scaladsl/server/directives/BasicDirectives.scala | 199 +++ | |
| akka-http/src/main/scala/akka/http/scaladsl/server/directives/CacheConditionDirectives.scala | 131 ++ | |
| akka-http/src/main/scala/akka/http/scaladsl/server/directives/CodingDirectives.scala | 145 ++ | |
| akka-http/src/main/scala/akka/http/scaladsl/server/directives/CookieDirectives.scala | 58 + | |
| akka-http/src/main/scala/akka/http/scaladsl/server/directives/DebuggingDirectives.scala | 95 ++ | |
| akka-http/src/main/scala/akka/http/scaladsl/server/directives/ExecutionDirectives.scala | 58 + | |
| akka-http/src/main/scala/akka/http/scaladsl/server/directives/FileAndResourceDirectives.scala | 339 +++++ | |
| akka-http/src/main/scala/akka/http/scaladsl/server/directives/FileUploadDirectives.scala | 91 ++ | |
| akka-http/src/main/scala/akka/http/scaladsl/server/directives/FormFieldDirectives.scala | 151 +++ | |
| akka-http/src/main/scala/akka/http/scaladsl/server/directives/FutureDirectives.scala | 81 ++ | |
| akka-http/src/main/scala/akka/http/scaladsl/server/directives/HeaderDirectives.scala | 110 ++ | |
| akka-http/src/main/scala/akka/http/scaladsl/server/directives/HostDirectives.scala | 63 + | |
| akka-http/src/main/scala/akka/http/scaladsl/server/directives/MarshallingDirectives.scala | 71 + | |
| akka-http/src/main/scala/akka/http/scaladsl/server/directives/MethodDirectives.scala | 101 ++ | |
| akka-http/src/main/scala/akka/http/scaladsl/server/directives/MiscDirectives.scala | 82 ++ | |
| akka-http/src/main/scala/akka/http/scaladsl/server/directives/ParameterDirectives.scala | 173 +++ | |
| akka-http/src/main/scala/akka/http/scaladsl/server/directives/PathDirectives.scala | 167 +++ | |
| akka-http/src/main/scala/akka/http/scaladsl/server/directives/RangeDirectives.scala | 156 +++ | |
| akka-http/src/main/scala/akka/http/scaladsl/server/directives/RespondWithDirectives.scala | 47 + | |
| akka-http/src/main/scala/akka/http/scaladsl/server/directives/RouteDirectives.scala | 59 + | |
| akka-http/src/main/scala/akka/http/scaladsl/server/directives/SchemeDirectives.scala | 27 + | |
| akka-http/src/main/scala/akka/http/scaladsl/server/directives/SecurityDirectives.scala | 253 ++++ | |
| akka-http/src/main/scala/akka/http/scaladsl/server/directives/WebsocketDirectives.scala | 65 + | |
| akka-http/src/main/scala/akka/http/scaladsl/server/package.scala | 19 + | |
| akka-http/src/main/scala/akka/http/scaladsl/server/util/ApplyConverter.scala | 18 + | |
| akka-http/src/main/scala/akka/http/scaladsl/server/util/BinaryPolyFunc.scala | 29 + | |
| akka-http/src/main/scala/akka/http/scaladsl/server/util/ClassMagnet.scala | 32 + | |
| akka-http/src/main/scala/akka/http/scaladsl/server/util/ConstructFromTuple.scala | 12 + | |
| akka-http/src/main/scala/akka/http/scaladsl/server/util/Tuple.scala | 42 + | |
| akka-http/src/main/scala/akka/http/scaladsl/server/util/TupleOps.scala | 66 + | |
| akka-http/src/main/scala/akka/http/scaladsl/server/util/Tupler.scala | 33 + | |
| akka-http/src/main/scala/akka/http/scaladsl/unmarshalling/GenericUnmarshallers.scala | 29 + | |
| akka-http/src/main/scala/akka/http/scaladsl/unmarshalling/MultipartUnmarshallers.scala | 111 ++ | |
| akka-http/src/main/scala/akka/http/scaladsl/unmarshalling/PredefinedFromEntityUnmarshallers.scala | 54 + | |
| akka-http/src/main/scala/akka/http/scaladsl/unmarshalling/PredefinedFromStringUnmarshallers.scala | 72 + | |
| akka-http/src/main/scala/akka/http/scaladsl/unmarshalling/Unmarshal.scala | 20 + | |
| akka-http/src/main/scala/akka/http/scaladsl/unmarshalling/Unmarshaller.scala | 147 ++ | |
| akka-http/src/main/scala/akka/http/scaladsl/unmarshalling/package.scala | 19 + | |
| akka-stream-tck/src/test/scala/akka/stream/tck/ActorPublisherTest.scala | 48 + | |
| akka-stream-tck/src/test/scala/akka/stream/tck/ActorSubscriberTest.scala | 28 + | |
| akka-stream-tck/src/test/scala/akka/stream/tck/ActorSystemLifecycle.scala | 44 + | |
| akka-stream-tck/src/test/scala/akka/stream/tck/AkkaIdentityProcessorVerification.scala | 52 + | |
| akka-stream-tck/src/test/scala/akka/stream/tck/AkkaPublisherVerification.scala | 41 + | |
| akka-stream-tck/src/test/scala/akka/stream/tck/AkkaSubscriberVerification.scala | 47 + | |
| akka-stream-tck/src/test/scala/akka/stream/tck/ConcatTest.scala | 16 + | |
| akka-stream-tck/src/test/scala/akka/stream/tck/EmptyPublisherTest.scala | 18 + | |
| akka-stream-tck/src/test/scala/akka/stream/tck/FanoutPublisherTest.scala | 21 + | |
| akka-stream-tck/src/test/scala/akka/stream/tck/FilePublisherTest.scala | 48 + | |
| akka-stream-tck/src/test/scala/akka/stream/tck/FlattenTest.scala | 19 + | |
| akka-stream-tck/src/test/scala/akka/stream/tck/FoldSinkSubscriberTest.scala | 15 + | |
| akka-stream-tck/src/test/scala/akka/stream/tck/ForeachSinkSubscriberTest.scala | 15 + | |
| akka-stream-tck/src/test/scala/akka/stream/tck/FusableProcessorTest.scala | 26 + | |
| akka-stream-tck/src/test/scala/akka/stream/tck/FuturePublisherTest.scala | 22 + | |
| akka-stream-tck/src/test/scala/akka/stream/tck/GroupByTest.scala | 31 + | |
| akka-stream-tck/src/test/scala/akka/stream/tck/InputStreamSourceTest.scala | 27 + | |
| akka-stream-tck/src/test/scala/akka/stream/tck/IterablePublisherTest.scala | 17 + | |
| akka-stream-tck/src/test/scala/akka/stream/tck/MapTest.scala | 21 + | |
| akka-stream-tck/src/test/scala/akka/stream/tck/MaybeSourceTest.scala | 20 + | |
| akka-stream-tck/src/test/scala/akka/stream/tck/PrefixAndTailTest.scala | 21 + | |
| akka-stream-tck/src/test/scala/akka/stream/tck/SingleElementSourceTest.scala | 18 + | |
| akka-stream-tck/src/test/scala/akka/stream/tck/SinkholeSubscriberTest.scala | 46 + | |
| akka-stream-tck/src/test/scala/akka/stream/tck/SplitWhenTest.scala | 30 + | |
| akka-stream-tck/src/test/scala/akka/stream/tck/Timeouts.scala | 19 + | |
| akka-stream-tck/src/test/scala/akka/stream/tck/TransformProcessorTest.scala | 31 + | |
| akka-stream-tck/src/test/scala/akka/stream/tck/VirtualPublisherTest.scala | 34 + | |
| akka-stream-testkit/src/main/scala/akka/stream/testkit/StreamTestKit.scala | 671 ++++++++++ | |
| akka-stream-testkit/src/main/scala/akka/stream/testkit/javadsl/TestSink.scala | 19 + | |
| akka-stream-testkit/src/main/scala/akka/stream/testkit/javadsl/TestSource.scala | 19 + | |
| akka-stream-testkit/src/main/scala/akka/stream/testkit/scaladsl/TestSink.scala | 24 + | |
| akka-stream-testkit/src/main/scala/akka/stream/testkit/scaladsl/TestSource.scala | 24 + | |
| akka-stream-testkit/src/test/resources/reference.conf | 23 + | |
| akka-stream-testkit/src/test/scala/akka/stream/testkit/AkkaSpec.scala | 105 ++ | |
| akka-stream-testkit/src/test/scala/akka/stream/testkit/BaseTwoStreamsSetup.scala | 75 ++ | |
| akka-stream-testkit/src/test/scala/akka/stream/testkit/ChainSetup.scala | 32 + | |
| akka-stream-testkit/src/test/scala/akka/stream/testkit/Coroner.scala | 271 ++++ | |
| akka-stream-testkit/src/test/scala/akka/stream/testkit/ScriptedTest.scala | 204 +++ | |
| akka-stream-testkit/src/test/scala/akka/stream/testkit/StreamTestDefaultMailbox.scala | 44 + | |
| akka-stream-testkit/src/test/scala/akka/stream/testkit/StreamTestKitSpec.scala | 125 ++ | |
| akka-stream-testkit/src/test/scala/akka/stream/testkit/TestPublisherSubscriberSpec.scala | 62 + | |
| akka-stream-testkit/src/test/scala/akka/stream/testkit/TestUtils.scala | 44 + | |
| akka-stream-testkit/src/test/scala/akka/stream/testkit/TwoStreamsSetup.scala | 35 + | |
| akka-stream-testkit/src/test/scala/akka/stream/testkit/Utils.scala | 52 + | |
| akka-stream-tests/src/test/java/akka/stream/StreamTest.java | 19 + | |
| akka-stream-tests/src/test/java/akka/stream/actor/ActorPublisherTest.java | 55 + | |
| akka-stream-tests/src/test/java/akka/stream/actor/ActorSubscriberTest.java | 75 ++ | |
| akka-stream-tests/src/test/java/akka/stream/io/InputStreamSinkTest.java | 49 + | |
| akka-stream-tests/src/test/java/akka/stream/io/OutputStreamSourceTest.java | 53 + | |
| akka-stream-tests/src/test/java/akka/stream/javadsl/AkkaJUnitActorSystemResource.java | 84 ++ | |
| akka-stream-tests/src/test/java/akka/stream/javadsl/AttributesTest.java | 38 + | |
| akka-stream-tests/src/test/java/akka/stream/javadsl/BidiFlowTest.java | 281 ++++ | |
| akka-stream-tests/src/test/java/akka/stream/javadsl/FlowGraphTest.java | 336 +++++ | |
| akka-stream-tests/src/test/java/akka/stream/javadsl/FlowTest.java | 793 +++++++++++ | |
| akka-stream-tests/src/test/java/akka/stream/javadsl/SinkTest.java | 106 ++ | |
| akka-stream-tests/src/test/java/akka/stream/javadsl/SourceTest.java | 781 +++++++++++ | |
| akka-stream-tests/src/test/java/akka/stream/javadsl/TcpTest.java | 125 ++ | |
| akka-stream-tests/src/test/java/akka/stream/stage/JavaIdentityStage.java | 49 + | |
| akka-stream-tests/src/test/java/akka/stream/stage/StageTest.java | 47 + | |
| akka-stream-tests/src/test/resources/badtruststore | Bin 0 -> 1208 bytes | |
| akka-stream-tests/src/test/resources/keystore | Bin 0 -> 1342 bytes | |
| akka-stream-tests/src/test/resources/reference.conf | 10 + | |
| akka-stream-tests/src/test/resources/truststore | Bin 0 -> 637 bytes | |
| akka-stream-tests/src/test/scala/akka/stream/ActorMaterializerSpec.scala | 70 + | |
| akka-stream-tests/src/test/scala/akka/stream/DslConsistencySpec.scala | 106 ++ | |
| akka-stream-tests/src/test/scala/akka/stream/DslFactoriesConsistencySpec.scala | 249 ++++ | |
| akka-stream-tests/src/test/scala/akka/stream/FusingSpec.scala | 148 +++ | |
| akka-stream-tests/src/test/scala/akka/stream/actor/ActorPublisherSpec.scala | 450 +++++++ | |
| akka-stream-tests/src/test/scala/akka/stream/actor/ActorSubscriberSpec.scala | 296 +++++ | |
| akka-stream-tests/src/test/scala/akka/stream/extra/FlowTimedSpec.scala | 125 ++ | |
| akka-stream-tests/src/test/scala/akka/stream/impl/FixedBufferSpec.scala | 97 ++ | |
| akka-stream-tests/src/test/scala/akka/stream/impl/GraphStageLogicSpec.scala | 155 +++ | |
| akka-stream-tests/src/test/scala/akka/stream/impl/ResizableMultiReaderRingBufferSpec.scala | 197 +++ | |
| akka-stream-tests/src/test/scala/akka/stream/impl/StreamLayoutSpec.scala | 240 ++++ | |
| akka-stream-tests/src/test/scala/akka/stream/impl/TimeoutsSpec.scala | 246 ++++ | |
| akka-stream-tests/src/test/scala/akka/stream/impl/fusing/ActorGraphInterpreterSpec.scala | 260 ++++ | |
| akka-stream-tests/src/test/scala/akka/stream/impl/fusing/GraphInterpreterFailureModesSpec.scala | 111 ++ | |
| akka-stream-tests/src/test/scala/akka/stream/impl/fusing/GraphInterpreterPortsSpec.scala | 1179 +++++++++++++++++ | |
| akka-stream-tests/src/test/scala/akka/stream/impl/fusing/GraphInterpreterSpec.scala | 384 ++++++ | |
| akka-stream-tests/src/test/scala/akka/stream/impl/fusing/GraphInterpreterSpecKit.scala | 430 ++++++ | |
| akka-stream-tests/src/test/scala/akka/stream/impl/fusing/InterpreterSpec.scala | 617 +++++++++ | |
| akka-stream-tests/src/test/scala/akka/stream/impl/fusing/InterpreterStressSpec.scala | 126 ++ | |
| akka-stream-tests/src/test/scala/akka/stream/impl/fusing/InterpreterSupervisionSpec.scala | 533 ++++++++ | |
| akka-stream-tests/src/test/scala/akka/stream/impl/fusing/IteratorInterpreterSpec.scala | 164 +++ | |
| akka-stream-tests/src/test/scala/akka/stream/impl/fusing/KeepGoingStageSpec.scala | 200 +++ | |
| akka-stream-tests/src/test/scala/akka/stream/impl/fusing/LifecycleInterpreterSpec.scala | 193 +++ | |
| akka-stream-tests/src/test/scala/akka/stream/io/FileSinkSpec.scala | 146 ++ | |
| akka-stream-tests/src/test/scala/akka/stream/io/FileSourceSpec.scala | 207 +++ | |
| akka-stream-tests/src/test/scala/akka/stream/io/FramingSpec.scala | 234 ++++ | |
| akka-stream-tests/src/test/scala/akka/stream/io/InputStreamSinkSpec.scala | 242 ++++ | |
| akka-stream-tests/src/test/scala/akka/stream/io/InputStreamSourceSpec.scala | 78 ++ | |
| akka-stream-tests/src/test/scala/akka/stream/io/OutputStreamSinkSpec.scala | 65 + | |
| akka-stream-tests/src/test/scala/akka/stream/io/OutputStreamSourceSpec.scala | 179 +++ | |
| akka-stream-tests/src/test/scala/akka/stream/io/TcpHelper.scala | 191 +++ | |
| akka-stream-tests/src/test/scala/akka/stream/io/TcpSpec.scala | 548 ++++++++ | |
| akka-stream-tests/src/test/scala/akka/stream/io/TlsSpec.scala | 452 +++++++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/AcknowledgeSourceSpec.scala | 96 ++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/ActorRefBackpressureSinkSpec.scala | 115 ++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/ActorRefSinkSpec.scala | 47 + | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/ActorRefSourceSpec.scala | 148 +++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/AttributesSpec.scala | 65 + | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/BidiFlowSpec.scala | 121 ++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowAppendSpec.scala | 64 + | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowBufferSpec.scala | 237 ++++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowCollectSpec.scala | 30 + | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowCompileSpec.scala | 129 ++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowConcatAllSpec.scala | 205 +++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowConcatSpec.scala | 192 +++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowConflateSpec.scala | 100 ++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowDelaySpec.scala | 127 ++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowDetacherSpec.scala | 53 + | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowDispatcherSpec.scala | 33 + | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowDropSpec.scala | 41 + | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowDropWhileSpec.scala | 48 + | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowDropWithinSpec.scala | 50 + | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowExpandSpec.scala | 130 ++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowFilterSpec.scala | 54 + | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowFlattenMergeSpec.scala | 173 +++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowFoldSpec.scala | 59 + | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowForeachSpec.scala | 57 + | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowFromFutureSpec.scala | 97 ++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowGraphCompileSpec.scala | 344 +++++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowGroupBySpec.scala | 315 +++++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowGroupedSpec.scala | 37 + | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowGroupedWithinSpec.scala | 140 ++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowIdleInjectSpec.scala | 149 +++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowInitialDelaySpec.scala | 52 + | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowInterleaveSpec.scala | 141 ++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowIntersperseSpec.scala | 102 ++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowIteratorSpec.scala | 191 +++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowJoinSpec.scala | 72 + | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowLimitSpec.scala | 65 + | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowLimitWeightedSpec.scala | 66 + | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowLogSpec.scala | 185 +++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowMapAsyncSpec.scala | 262 ++++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowMapAsyncUnorderedSpec.scala | 249 ++++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowMapConcatSpec.scala | 47 + | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowMapSpec.scala | 44 + | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowMergeSpec.scala | 100 ++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowOnCompleteSpec.scala | 83 ++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowPrefixAndTailSpec.scala | 256 ++++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowRecoverSpec.scala | 74 ++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowScanSpec.scala | 58 + | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowSectionSpec.scala | 93 ++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowSlidingSpec.scala | 61 + | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowSpec.scala | 598 +++++++++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowSplitAfterSpec.scala | 257 ++++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowSplitWhenSpec.scala | 346 +++++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowStageSpec.scala | 457 +++++++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowSupervisionSpec.scala | 62 + | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowTakeSpec.scala | 50 + | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowTakeWhileSpec.scala | 50 + | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowTakeWithinSpec.scala | 53 + | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowThrottleSpec.scala | 245 ++++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowZipSpec.scala | 72 + | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowZipWithSpec.scala | 92 ++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/GraphBackedFlowSpec.scala | 351 +++++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/GraphBalanceSpec.scala | 256 ++++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/GraphBroadcastSpec.scala | 245 ++++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/GraphConcatSpec.scala | 153 +++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/GraphMatValueSpec.scala | 120 ++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/GraphMergePreferredSpec.scala | 85 ++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/GraphMergeSortedSpec.scala | 52 + | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/GraphMergeSpec.scala | 178 +++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/GraphOpsIntegrationSpec.scala | 203 +++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/GraphPartialSpec.scala | 119 ++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/GraphStageTimersSpec.scala | 223 ++++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/GraphUnzipSpec.scala | 148 +++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/GraphUnzipWithSpec.scala | 302 +++++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/GraphZipSpec.scala | 234 ++++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/GraphZipWithSpec.scala | 183 +++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/HeadSinkSpec.scala | 89 ++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/ImplicitMaterializerSpec.scala | 40 + | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/LastSinkSpec.scala | 63 + | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/One2OneBidiFlowSpec.scala | 90 ++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/PublisherSinkSpec.scala | 56 + | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/QueueSinkSpec.scala | 101 ++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/ReverseArrowSpec.scala | 200 +++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/SeqSinkSpec.scala | 33 + | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/SinkForeachParallelSpec.scala | 125 ++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/SinkSpec.scala | 129 ++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/SourceSpec.scala | 278 ++++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/StageActorRefSpec.scala | 238 ++++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/SubscriberSinkSpec.scala | 32 + | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/SubscriberSourceSpec.scala | 29 + | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/SubstreamSubscriptionTimeoutSpec.scala | 140 ++ | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/TestConfig.scala | 10 + | |
| akka-stream-tests/src/test/scala/akka/stream/scaladsl/TickSourceSpec.scala | 107 ++ | |
| akka-stream/src/main/boilerplate/akka/stream/FanInShape.scala.template | 92 ++ | |
| akka-stream/src/main/boilerplate/akka/stream/FanOutShape.scala.template | 76 ++ | |
| akka-stream/src/main/boilerplate/akka/stream/javadsl/GraphCreate.scala.template | 42 + | |
| akka-stream/src/main/boilerplate/akka/stream/javadsl/UnzipWith.scala.template | 43 + | |
| akka-stream/src/main/boilerplate/akka/stream/javadsl/ZipWith.scala.template | 42 + | |
| akka-stream/src/main/boilerplate/akka/stream/scaladsl/GraphApply.scala.template | 69 + | |
| akka-stream/src/main/boilerplate/akka/stream/scaladsl/UnzipWithApply.scala.template | 91 ++ | |
| akka-stream/src/main/boilerplate/akka/stream/scaladsl/ZipWithApply.scala.template | 73 + | |
| akka-stream/src/main/resources/reference.conf | 85 ++ | |
| akka-stream/src/main/scala/akka/stream/ActorMaterializer.scala | 484 +++++++ | |
| akka-stream/src/main/scala/akka/stream/Attributes.scala | 289 ++++ | |
| akka-stream/src/main/scala/akka/stream/Fusing.scala | 66 + | |
| akka-stream/src/main/scala/akka/stream/Graph.scala | 30 + | |
| akka-stream/src/main/scala/akka/stream/Materializer.scala | 84 ++ | |
| akka-stream/src/main/scala/akka/stream/OverflowStrategy.scala | 125 ++ | |
| akka-stream/src/main/scala/akka/stream/Queue.scala | 37 + | |
| akka-stream/src/main/scala/akka/stream/Shape.scala | 342 +++++ | |
| akka-stream/src/main/scala/akka/stream/StreamLimitReachedException.scala | 3 + | |
| akka-stream/src/main/scala/akka/stream/StreamTcpException.scala | 16 + | |
| akka-stream/src/main/scala/akka/stream/Supervision.scala | 93 ++ | |
| akka-stream/src/main/scala/akka/stream/ThrottleMode.scala | 28 + | |
| akka-stream/src/main/scala/akka/stream/Transformer.scala | 48 + | |
| akka-stream/src/main/scala/akka/stream/actor/ActorPublisher.scala | 457 +++++++ | |
| akka-stream/src/main/scala/akka/stream/actor/ActorSubscriber.scala | 369 ++++++ | |
| akka-stream/src/main/scala/akka/stream/extra/Implicits.scala | 56 + | |
| akka-stream/src/main/scala/akka/stream/extra/Timed.scala | 159 +++ | |
| akka-stream/src/main/scala/akka/stream/impl/AcknowledgePublisher.scala | 92 ++ | |
| akka-stream/src/main/scala/akka/stream/impl/ActorMaterializerImpl.scala | 318 +++++ | |
| akka-stream/src/main/scala/akka/stream/impl/ActorProcessor.scala | 300 +++++ | |
| akka-stream/src/main/scala/akka/stream/impl/ActorPublisher.scala | 129 ++ | |
| akka-stream/src/main/scala/akka/stream/impl/ActorRefBackpressureSinkStage.scala | 86 ++ | |
| akka-stream/src/main/scala/akka/stream/impl/ActorRefSinkActor.scala | 45 + | |
| akka-stream/src/main/scala/akka/stream/impl/ActorRefSourceActor.scala | 107 ++ | |
| akka-stream/src/main/scala/akka/stream/impl/BoundedBuffer.scala | 104 ++ | |
| akka-stream/src/main/scala/akka/stream/impl/CompletedPublishers.scala | 118 ++ | |
| akka-stream/src/main/scala/akka/stream/impl/ConstantFun.scala | 23 + | |
| akka-stream/src/main/scala/akka/stream/impl/Emit.scala | 33 + | |
| akka-stream/src/main/scala/akka/stream/impl/ExposedPublisherReceive.scala | 30 + | |
| akka-stream/src/main/scala/akka/stream/impl/FanIn.scala | 293 ++++ | |
| akka-stream/src/main/scala/akka/stream/impl/FanOut.scala | 317 +++++ | |
| akka-stream/src/main/scala/akka/stream/impl/FanoutProcessor.scala | 129 ++ | |
| akka-stream/src/main/scala/akka/stream/impl/FixedSizeBuffer.scala | 84 ++ | |
| akka-stream/src/main/scala/akka/stream/impl/FlowModule.scala | 23 + | |
| akka-stream/src/main/scala/akka/stream/impl/GroupByProcessorImpl.scala | 101 ++ | |
| akka-stream/src/main/scala/akka/stream/impl/Messages.scala | 32 + | |
| akka-stream/src/main/scala/akka/stream/impl/Modules.scala | 152 +++ | |
| akka-stream/src/main/scala/akka/stream/impl/ReactiveStreamsCompliance.scala | 121 ++ | |
| akka-stream/src/main/scala/akka/stream/impl/ResizableMultiReaderRingBuffer.scala | 152 +++ | |
| akka-stream/src/main/scala/akka/stream/impl/SeqActorName.scala | 28 + | |
| akka-stream/src/main/scala/akka/stream/impl/SinkholeSubscriber.scala | 34 + | |
| akka-stream/src/main/scala/akka/stream/impl/Sinks.scala | 328 +++++ | |
| akka-stream/src/main/scala/akka/stream/impl/Stages.scala | 219 +++ | |
| akka-stream/src/main/scala/akka/stream/impl/StreamLayout.scala | 709 ++++++++++ | |
| akka-stream/src/main/scala/akka/stream/impl/StreamOfStreamProcessors.scala | 427 ++++++ | |
| akka-stream/src/main/scala/akka/stream/impl/StreamSubscriptionTimeout.scala | 114 ++ | |
| akka-stream/src/main/scala/akka/stream/impl/SubFlowImpl.scala | 39 + | |
| akka-stream/src/main/scala/akka/stream/impl/SubscriberManagement.scala | 271 ++++ | |
| akka-stream/src/main/scala/akka/stream/impl/Throttle.scala | 81 ++ | |
| akka-stream/src/main/scala/akka/stream/impl/Timers.scala | 237 ++++ | |
| akka-stream/src/main/scala/akka/stream/impl/Transfer.scala | 208 +++ | |
| akka-stream/src/main/scala/akka/stream/impl/Unfold.scala | 63 + | |
| akka-stream/src/main/scala/akka/stream/impl/fusing/ActorGraphInterpreter.scala | 568 ++++++++ | |
| akka-stream/src/main/scala/akka/stream/impl/fusing/Fusing.scala | 717 ++++++++++ | |
| akka-stream/src/main/scala/akka/stream/impl/fusing/GraphInterpreter.scala | 767 +++++++++++ | |
| akka-stream/src/main/scala/akka/stream/impl/fusing/GraphStages.scala | 223 ++++ | |
| akka-stream/src/main/scala/akka/stream/impl/fusing/IteratorInterpreter.scala | 157 +++ | |
| akka-stream/src/main/scala/akka/stream/impl/fusing/Ops.scala | 976 ++++++++++++++ | |
| akka-stream/src/main/scala/akka/stream/impl/fusing/StreamOfStreams.scala | 527 ++++++++ | |
| akka-stream/src/main/scala/akka/stream/impl/io/FilePublisher.scala | 110 ++ | |
| akka-stream/src/main/scala/akka/stream/impl/io/FileSubscriber.scala | 81 ++ | |
| akka-stream/src/main/scala/akka/stream/impl/io/IOSinks.scala | 69 + | |
| akka-stream/src/main/scala/akka/stream/impl/io/IOSources.scala | 76 ++ | |
| akka-stream/src/main/scala/akka/stream/impl/io/InputStreamPublisher.scala | 80 ++ | |
| akka-stream/src/main/scala/akka/stream/impl/io/InputStreamSinkStage.scala | 202 +++ | |
| akka-stream/src/main/scala/akka/stream/impl/io/OutputStreamSourceStage.scala | 184 +++ | |
| akka-stream/src/main/scala/akka/stream/impl/io/OutputStreamSubscriber.scala | 59 + | |
| akka-stream/src/main/scala/akka/stream/impl/io/SslTlsCipherActor.scala | 466 +++++++ | |
| akka-stream/src/main/scala/akka/stream/impl/io/TcpStages.scala | 343 +++++ | |
| akka-stream/src/main/scala/akka/stream/io/ByteStringParser.scala | 120 ++ | |
| akka-stream/src/main/scala/akka/stream/io/Framing.scala | 265 ++++ | |
| akka-stream/src/main/scala/akka/stream/io/SslTls.scala | 446 +++++++ | |
| akka-stream/src/main/scala/akka/stream/javadsl/BidiFlow.scala | 219 +++ | |
| akka-stream/src/main/scala/akka/stream/javadsl/FileIO.scala | 73 + | |
| akka-stream/src/main/scala/akka/stream/javadsl/Flow.scala | 1668 +++++++++++++++++++++++ | |
| akka-stream/src/main/scala/akka/stream/javadsl/Graph.scala | 342 +++++ | |
| akka-stream/src/main/scala/akka/stream/javadsl/Keep.scala | 19 + | |
| akka-stream/src/main/scala/akka/stream/javadsl/Sink.scala | 286 ++++ | |
| akka-stream/src/main/scala/akka/stream/javadsl/Source.scala | 1749 ++++++++++++++++++++++++ | |
| akka-stream/src/main/scala/akka/stream/javadsl/StreamConverters.scala | 112 ++ | |
| akka-stream/src/main/scala/akka/stream/javadsl/SubFlow.scala | 1173 ++++++++++++++++ | |
| akka-stream/src/main/scala/akka/stream/javadsl/SubSource.scala | 1170 ++++++++++++++++ | |
| akka-stream/src/main/scala/akka/stream/javadsl/Tcp.scala | 177 +++ | |
| akka-stream/src/main/scala/akka/stream/javadsl/package.scala | 12 + | |
| akka-stream/src/main/scala/akka/stream/scaladsl/BidiFlow.scala | 235 ++++ | |
| akka-stream/src/main/scala/akka/stream/scaladsl/FileIO.scala | 52 + | |
| akka-stream/src/main/scala/akka/stream/scaladsl/Flow.scala | 1798 +++++++++++++++++++++++++ | |
| akka-stream/src/main/scala/akka/stream/scaladsl/Graph.scala | 1052 +++++++++++++++ | |
| akka-stream/src/main/scala/akka/stream/scaladsl/ImplicitMaterializer.scala | 26 + | |
| akka-stream/src/main/scala/akka/stream/scaladsl/Materialization.scala | 20 + | |
| akka-stream/src/main/scala/akka/stream/scaladsl/One2OneBidiFlow.scala | 82 ++ | |
| akka-stream/src/main/scala/akka/stream/scaladsl/Sink.scala | 321 +++++ | |
| akka-stream/src/main/scala/akka/stream/scaladsl/Source.scala | 441 ++++++ | |
| akka-stream/src/main/scala/akka/stream/scaladsl/StreamConverters.scala | 79 ++ | |
| akka-stream/src/main/scala/akka/stream/scaladsl/SubFlow.scala | 56 + | |
| akka-stream/src/main/scala/akka/stream/scaladsl/Tcp.scala | 184 +++ | |
| akka-stream/src/main/scala/akka/stream/scaladsl/package.scala | 55 + | |
| akka-stream/src/main/scala/akka/stream/stage/GraphStage.scala | 1344 +++++++++++++++++++ | |
| akka-stream/src/main/scala/akka/stream/stage/Stage.scala | 673 ++++++++++ | |
| 1295 files changed, 152799 insertions(+) | |
| master-of-the-streams!akka-second $> |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment