File tree
1,091 files changed
+1092
-1092
lines changed- amqp/src
- main/scala/akka/stream/alpakka/amqp
- impl
- javadsl
- scaladsl
- test
- java
- akka/stream/alpakka/amqp/javadsl
- docs/javadsl
- scala
- akka/stream/alpakka/amqp
- scaladsl
- docs/scaladsl
- avroparquet-tests/src/test
- java/docs/javadsl
- scala/docs/scaladsl
- avroparquet/src/main/scala/akka/stream/alpakka/avroparquet
- impl
- javadsl
- scaladsl
- aws-event-bridge/src
- main/scala/akka/stream/alpakka/aws/eventbridge
- javadsl
- scaladsl
- test
- java/docs/javadsl
- scala
- akka/stream/alpakka/aws/eventbridge
- docs/scaladsl
- awslambda/src
- main/scala/akka/stream/alpakka/awslambda
- javadsl
- scaladsl
- test
- java/docs/javadsl
- scala/docs/scaladsl
- azure-storage-queue/src
- main/scala/akka/stream/alpakka/azure/storagequeue
- impl
- javadsl
- scaladsl
- test
- java/docs/javadsl
- scala/docs/scaladsl
- azure-storage/src
- main/scala/akka/stream/alpakka/azure/storage
- headers
- impl
- auth
- javadsl
- requests
- scaladsl
- test
- java/docs/javadsl
- scala
- akka/stream/alpakka/azure/storage
- impl/auth
- scaladsl
- docs/scaladsl
- cassandra/src
- main/scala/akka/stream/alpakka/cassandra
- javadsl
- scaladsl
- test
- java/docs/javadsl
- scala
- akka/stream/alpakka/cassandra/scaladsl
- docs
- javadsl
- scaladsl
- couchbase/src
- main
- java/akka/stream/alpakka/couchbase/javadsl
- scala/akka/stream/alpakka/couchbase
- impl
- javadsl
- scaladsl
- test
- java/docs/javadsl
- scala
- akka/stream/alpakka/couchbase/testing
- docs/scaladsl
- csv/src
- main
- java/akka/stream/alpakka/csv/javadsl
- scala/akka/stream/alpakka/csv
- impl
- scaladsl
- test
- java/docs/javadsl
- scala
- akka/stream/alpakka/csv
- docs/scaladsl
- doc-examples/src/test
- java/akka/stream/alpakka/eip/javadsl
- scala/akka/stream/alpakka/eip/scaladsl
- dynamodb/src
- main/scala/akka/stream/alpakka/dynamodb
- javadsl
- scaladsl
- test
- java/docs/javadsl
- scala
- akka/stream/alpakka/dynamodb
- docs/scaladsl
- elasticsearch/src
- main
- java/akka/stream/alpakka/elasticsearch
- scala/akka/stream/alpakka/elasticsearch
- impl
- javadsl
- scaladsl
- testkit
- test
- java/docs/javadsl
- scala
- akka/stream/alpakka/elasticsearch
- impl
- docs/scaladsl
- file/src
- main
- java/akka/stream/alpakka/file
- impl
- javadsl
- scala/akka/stream/alpakka/file
- impl/archive
- javadsl
- scaladsl
- test
- java/docs/javadsl
- scala
- akka/stream/alpakka/file/impl/archive
- docs/scaladsl
- ftp/src
- main/scala/akka/stream/alpakka/ftp
- impl
- javadsl
- scaladsl
- test
- java
- akka/stream/alpakka/ftp
- docs/javadsl
- scala
- akka/stream/alpakka/ftp
- docs/scaladsl
- geode/src
- main
- java/akka/stream/alpakka/geode/javadsl
- scala/akka/stream/alpakka/geode
- impl
- pdx
- stage
- scaladsl
- test
- java/docs/javadsl
- scala
- akka/stream/alpakka/geode/impl/pdx
- docs/scaladsl
- google-cloud-bigquery-storage/src
- main/scala/akka/stream/alpakka/googlecloud/bigquery/storage
- impl
- javadsl
- scaladsl
- test
- java
- akka/stream/alpakka/googlecloud/bigquery/storage/javadsl
- docs/javadsl
- scala
- akka/stream/alpakka/googlecloud/bigquery/storage
- mock
- scaladsl
- docs/scaladsl
- google-cloud-bigquery/src
- main/scala/akka/stream/alpakka/googlecloud/bigquery
- javadsl
- jackson
- model
- scaladsl
- schema
- spray
- test
- java
- akka/stream/alpakka/googlecloud/bigquery/e2e/javadsl
- docs/javadsl
- scala
- akka/stream/alpakka/googlecloud/bigquery
- e2e
- javadsl
- scaladsl
- scaladsl
- schema
- spray
- docs/scaladsl
- google-cloud-pub-sub-grpc/src
- main/scala/akka/stream/alpakka/googlecloud/pubsub/grpc
- impl
- javadsl
- scaladsl
- test
- java/docs/javadsl
- scala/docs/scaladsl
- google-cloud-pub-sub/src
- main/scala/akka/stream/alpakka/googlecloud/pubsub
- impl
- javadsl
- scaladsl
- test
- java/docs/javadsl
- scala
- akka/stream/alpakka/googlecloud/pubsub
- impl
- docs/scaladsl
- google-cloud-storage/src
- main/scala/akka/stream/alpakka/googlecloud/storage
- impl
- javadsl
- scaladsl
- test
- java/docs/javadsl
- scala
- akka/stream/alpakka/googlecloud/storage
- impl
- scaladsl
- docs/scaladsl
- google-common/src
- main
- java/akka/stream/alpakka/google/javadsl
- scala/akka/stream/alpakka/google
- auth
- http
- javadsl
- scaladsl
- util
- test
- java/docs/javadsl
- scala
- akka/stream/alpakka/google
- auth
- http
- util
- docs/scaladsl
- google-fcm/src
- main/scala/akka/stream/alpakka/google/firebase/fcm
- impl
- javadsl
- scaladsl
- v1
- impl
- javadsl
- models
- scaladsl
- test
- java/docs/javadsl
- scala
- akka/stream/alpakka/google/firebase/fcm/v1
- impl
- docs/scaladsl
- hbase/src
- main/scala/akka/stream/alpakka/hbase
- impl
- javadsl
- scaladsl
- test
- java/docs/javadsl
- scala/docs/scaladsl
- hdfs/src
- main/scala/akka/stream/alpakka/hdfs
- impl
- strategy
- writer
- javadsl
- scaladsl
- test
- java/docs/javadsl
- scala
- akka/stream/alpakka/hdfs/util
- docs/scaladsl
- huawei-push-kit/src
- main/scala/akka/stream/alpakka/huawei/pushkit
- impl
- javadsl
- models
- scaladsl
- test
- java/docs/javadsl
- scala
- akka/stream/alpakka/huawei/pushkit
- impl
- docs/scaladsl
- influxdb/src
- main/scala/akka/stream/alpakka/influxdb
- impl
- javadsl
- scaladsl
- test
- java/docs/javadsl
- scala/docs/scaladsl
- ironmq/src
- main/scala/akka/stream/alpakka/ironmq
- impl
- javadsl
- scaladsl
- test
- java
- akka/stream/alpakka/ironmq
- javadsl
- docs/javadsl
- scala
- akka/stream/alpakka/ironmq
- impl
- scaladsl
- docs/scaladsl
- jakarta-jms/src
- main/scala/akka/stream/alpakka/jakartajms
- impl
- javadsl
- scaladsl
- test
- java
- akka/stream/alpakka/jakartajms/javadsl
- docs/javadsl
- scala
- akka/stream/alpakka/jakartajms
- impl
- scaladsl
- docs/scaladsl
- jakartajmstestkit
- jms/src
- main/scala/akka/stream/alpakka/jms
- impl
- javadsl
- scaladsl
- test
- java
- akka/stream/alpakka/jms/javadsl
- docs/javadsl
- scala
- akka/stream/alpakka/jms
- impl
- scaladsl
- docs/scaladsl
- json-streaming/src
- main/scala/akka/stream/alpakka/json
- impl
- javadsl
- scaladsl
- test
- java/docs/javadsl
- scala/docs/scaladsl
- kinesis/src
- main/scala/akka/stream/alpakka
- kinesisfirehose
- javadsl
- scaladsl
- kinesis
- impl
- javadsl
- scaladsl
- test
- java
- akka/stream/alpakka/kinesis/javadsl
- docs/javadsl
- scala
- akka/stream/alpakka
- kinesisfirehose
- kinesis
- docs/scaladsl
- mongodb/src
- main/scala/akka/stream/alpakka/mongodb
- javadsl
- scaladsl
- test
- java/docs/javadsl
- scala/docs/scaladsl
- mqtt-streaming/src
- main/scala/akka/stream/alpakka/mqtt/streaming
- impl
- javadsl
- scaladsl
- test
- java/docs/javadsl
- scala
- akka/stream/alpakka/mqtt/streaming/impl
- docs/scaladsl
- mqtt/src
- main/scala/akka/stream/alpakka/mqtt
- impl
- javadsl
- scaladsl
- test
- java/docs/javadsl
- scala/docs/scaladsl
- pravega/src
- main
- java/akka/stream/alpakka/pravega/javadsl
- scala/akka/stream/alpakka/pravega
- impl
- scaladsl
- test
- java
- akka/stream/alpakka/pravega
- docs/javadsl
- scala
- akka/stream/alpakka/pravega
- docs/scaladsl
- project
- reference/src
- main/scala/akka/stream/alpakka/reference
- impl
- javadsl
- scaladsl
- testkit
- test
- java/docs/javadsl
- scala/docs/scaladsl
- s3/src
- main/scala/akka/stream/alpakka/s3
- headers
- impl
- auth
- javadsl
- scaladsl
- test
- java/docs/javadsl
- scala
- akka/stream/alpakka/s3
- impl
- auth
- scaladsl
- docs/scaladsl
- simple-codecs/src
- main/scala/akka/stream/alpakka/recordio
- impl
- javadsl
- scaladsl
- test
- java/docs/javadsl
- scala/docs/scaladsl
- slick/src
- main/scala/akka/stream/alpakka/slick
- javadsl
- scaladsl
- test
- java/docs/javadsl
- scala/docs/scaladsl
- sns/src
- main/scala/akka/stream/alpakka/sns
- javadsl
- scaladsl
- test
- java/docs/javadsl
- scala
- akka/stream/alpakka/sns
- docs/scaladsl
- solr/src
- main/scala/akka/stream/alpakka/solr
- impl
- javadsl
- scaladsl
- test
- java/docs/javadsl
- scala/docs/scaladsl
- spring-web/src
- main/java/akka/stream/alpakka/spring/web
- test/java/docs/javadsl
- sqs/src
- main/scala/akka/stream/alpakka/sqs
- impl
- javadsl
- scaladsl
- testkit
- test
- java
- akka/stream/alpakka/sqs/javadsl
- docs/javadsl
- scala
- akka/stream/alpakka/sqs
- scaladsl
- docs/scaladsl
- sse/src
- main/scala/akka/stream/alpakka/sse
- javadsl
- scaladsl
- test
- java/docs/javadsl
- scala/docs/scaladsl
- text/src
- main/scala/akka/stream/alpakka/text
- impl
- javadsl
- scaladsl
- test
- java/docs/javadsl
- scala
- akka/stream/alpakka/text/scaladsl
- docs/scaladsl
- udp/src
- main/scala/akka/stream/alpakka/udp
- impl
- javadsl
- scaladsl
- test
- java/docs/javadsl
- scala/docs/scaladsl
- unix-domain-socket/src
- main/scala/akka/stream/alpakka/unixdomainsocket
- impl
- javadsl
- scaladsl
- test
- java/docs/javadsl
- scala/docs/scaladsl
- xml/src
- main
- java/akka/stream/alpakka/xml
- scala/akka/stream/alpakka/xml
- impl
- javadsl
- scaladsl
- test
- java/docs/javadsl
- scala/docs/scaladsl
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
1,091 files changed
+1092
-1092
lines changedLines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | | - | |
| 2 | + | |
3 | 3 | | |
4 | 4 | | |
5 | 5 | | |
| |||
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | | - | |
| 2 | + | |
3 | 3 | | |
4 | 4 | | |
5 | 5 | | |
| |||
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | | - | |
| 2 | + | |
3 | 3 | | |
4 | 4 | | |
5 | 5 | | |
| |||
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | | - | |
| 2 | + | |
3 | 3 | | |
4 | 4 | | |
5 | 5 | | |
| |||
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | | - | |
| 2 | + | |
3 | 3 | | |
4 | 4 | | |
5 | 5 | | |
| |||
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | | - | |
| 2 | + | |
3 | 3 | | |
4 | 4 | | |
5 | 5 | | |
| |||
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | | - | |
| 2 | + | |
3 | 3 | | |
4 | 4 | | |
5 | 5 | | |
| |||
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | | - | |
| 2 | + | |
3 | 3 | | |
4 | 4 | | |
5 | 5 | | |
| |||
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | | - | |
| 2 | + | |
3 | 3 | | |
4 | 4 | | |
5 | 5 | | |
| |||
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | | - | |
| 2 | + | |
3 | 3 | | |
4 | 4 | | |
5 | 5 | | |
| |||
0 commit comments