Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 3 additions & 0 deletions .git-blame-ignore-revs
Original file line number Diff line number Diff line change
Expand Up @@ -16,3 +16,6 @@ a904e917d5851ebffc5e1eabbee70cf1685c4263

# Scala Steward: Reformat with scalafmt 3.10.4
3a1f225850c219c27f8f1b30699aec4eea45923e

# Scala Steward: Reformat with scalafmt 3.10.5
66cba5fda8ea1213f1ee8d0732f25d1fc44aecdd
2 changes: 1 addition & 1 deletion .scalafmt.conf
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
version = 3.10.4
version = 3.10.5
runner.dialect = scala213
project.git = true
style = defaultWithAlign
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,14 @@ import scala.concurrent.Await
import scala.concurrent.duration.{ Duration, DurationInt }

import org.openjdk.jmh.annotations.{
Benchmark, BenchmarkMode, Mode, OperationsPerInvocation, OutputTimeUnit, Scope, State, TearDown
Benchmark,
BenchmarkMode,
Mode,
OperationsPerInvocation,
OutputTimeUnit,
Scope,
State,
TearDown
}

import org.apache.pekko
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,13 @@ import org.apache.pekko
import pekko.http.impl.engine.http2.FrameEvent.{ DataFrame, HeadersFrame }
import pekko.http.impl.engine.http2.framing.FrameRenderer
import pekko.http.scaladsl.model.{
AttributeKeys, ContentTypes, HttpEntity, HttpMethods, HttpRequest, HttpResponse, Trailer
AttributeKeys,
ContentTypes,
HttpEntity,
HttpMethods,
HttpRequest,
HttpResponse,
Trailer
}
import pekko.http.scaladsl.model.HttpEntity.{ Chunk, LastChunk }
import pekko.http.scaladsl.model.headers.RawHeader
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,13 @@ package org.apache.pekko.http.impl.engine.client
import org.apache.pekko
import pekko.Done
import pekko.actor.{
Actor, ActorLogging, ActorRef, DeadLetterSuppression, Deploy, ExtendedActorSystem, NoSerializationVerificationNeeded,
Actor,
ActorLogging,
ActorRef,
DeadLetterSuppression,
Deploy,
ExtendedActorSystem,
NoSerializationVerificationNeeded,
Props
}
import pekko.annotation.InternalApi
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,13 +15,21 @@ package org.apache.pekko.http.impl.engine.http2

import org.apache.pekko
import pekko.actor.{
ActorSystem, ClassicActorSystemProvider, ExtendedActorSystem, Extension, ExtensionId, ExtensionIdProvider
ActorSystem,
ClassicActorSystemProvider,
ExtendedActorSystem,
Extension,
ExtensionId,
ExtensionIdProvider
}
import pekko.annotation.InternalApi
import pekko.event.LoggingAdapter
import pekko.http.impl.engine.HttpConnectionIdleTimeoutBidi
import pekko.http.impl.engine.server.{
GracefulTerminatorStage, MasterServerTerminator, ServerTerminator, UpgradeToOtherProtocolResponseHeader
GracefulTerminatorStage,
MasterServerTerminator,
ServerTerminator,
UpgradeToOtherProtocolResponseHeader
}
import pekko.http.impl.util.LogByteStringTools
import pekko.http.scaladsl.Http.OutgoingConnection
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,11 @@ import pekko.http.impl.util.LogByteStringTools.logTLSBidiBySetting
import pekko.http.impl.util.StreamUtils
import pekko.http.scaladsl.model._
import pekko.http.scaladsl.settings.{
ClientConnectionSettings, Http2ClientSettings, Http2ServerSettings, ParserSettings, ServerSettings
ClientConnectionSettings,
Http2ClientSettings,
Http2ServerSettings,
ParserSettings,
ServerSettings
}
import pekko.stream.{ BidiShape, Graph, StreamTcpException, ThrottleMode }
import pekko.stream.TLSProtocol._
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,12 @@ import pekko.stream.Inlet
import pekko.stream.Outlet
import pekko.stream.scaladsl.Source
import pekko.stream.stage.{
GraphStageLogic, GraphStageWithMaterializedValue, InHandler, OutHandler, StageLogging, TimerGraphStageLogic
GraphStageLogic,
GraphStageWithMaterializedValue,
InHandler,
OutHandler,
StageLogging,
TimerGraphStageLogic
}
import pekko.util.ByteString
import pekko.util.OptionVal
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,9 @@ import pekko.http.impl.util.HttpConstants._
import pekko.http.scaladsl.model.{ ErrorInfo, HttpHeader, MediaTypes, StatusCode, StatusCodes }
import pekko.http.scaladsl.model.headers.{ EmptyHeader, RawHeader }
import pekko.http.scaladsl.settings.ParserSettings.{
ErrorLoggingVerbosity, IllegalResponseHeaderNameProcessingMode, IllegalResponseHeaderValueProcessingMode
ErrorLoggingVerbosity,
IllegalResponseHeaderNameProcessingMode,
IllegalResponseHeaderValueProcessingMode
}
import pekko.util.ByteString

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,10 @@ import pekko.http.impl.engine.parsing.ParserOutput._
import pekko.http.impl.engine.parsing._
import pekko.http.impl.engine.rendering.ResponseRenderingContext.CloseRequested
import pekko.http.impl.engine.rendering.{
DateHeaderRendering, HttpResponseRendererFactory, ResponseRenderingContext, ResponseRenderingOutput
DateHeaderRendering,
HttpResponseRendererFactory,
ResponseRenderingContext,
ResponseRenderingOutput
}
import pekko.http.impl.util._
import pekko.http.javadsl.model
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,8 @@ import pekko.annotation.InternalApi
import pekko.http.scaladsl.settings.ParserSettings
import pekko.http.scaladsl.settings.ParserSettings.CookieParsingMode
import pekko.http.scaladsl.settings.ParserSettings.{
IllegalResponseHeaderNameProcessingMode, IllegalResponseHeaderValueProcessingMode
IllegalResponseHeaderNameProcessingMode,
IllegalResponseHeaderValueProcessingMode
}
import pekko.http.scaladsl.model.headers.HttpCookiePair
import pekko.util.ConstantFun
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -18,8 +18,11 @@ import org.apache.pekko
import pekko.annotation.InternalApi
import pekko.http.impl.util._
import pekko.http.scaladsl.settings.ParserSettings.{
ConflictingContentTypeHeaderProcessingMode, CookieParsingMode, ErrorLoggingVerbosity,
IllegalResponseHeaderNameProcessingMode, IllegalResponseHeaderValueProcessingMode
ConflictingContentTypeHeaderProcessingMode,
CookieParsingMode,
ErrorLoggingVerbosity,
IllegalResponseHeaderNameProcessingMode,
IllegalResponseHeaderValueProcessingMode
}
import pekko.http.scaladsl.model._
import pekko.http.scaladsl.settings.ParserSettings
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,11 @@ import pekko.NotUsed
import pekko.annotation.InternalApi
import pekko.http.impl.model.{ JavaQuery, JavaUri }
import pekko.http.javadsl.{
model => jm, settings => js, ConnectionContext, HttpConnectionContext, HttpsConnectionContext
model => jm,
settings => js,
ConnectionContext,
HttpConnectionContext,
HttpsConnectionContext
}
import pekko.http.{ javadsl => jdsl, scaladsl => sdsl }
import pekko.http.scaladsl.{ model => sm }
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,11 @@ package org.apache.pekko.http.impl.engine.client
import org.apache.pekko
import pekko.actor.ActorSystem
import pekko.http.scaladsl.settings.{
ClientConnectionSettings, ConnectionPoolSettings, HttpsProxySettings, ParserSettings, ServerSettings
ClientConnectionSettings,
ConnectionPoolSettings,
HttpsProxySettings,
ParserSettings,
ServerSettings
}
import pekko.testkit.PekkoSpec
import com.typesafe.config.ConfigFactory
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,11 @@ import pekko.http.impl.engine.server.ServerTerminator
import pekko.http.impl.engine.ws.ByteStringSinkProbe
import pekko.http.impl.util._
import pekko.http.scaladsl.Http.{
HostConnectionPool, HostConnectionPoolImpl, HttpServerTerminated, HttpTerminated, OutgoingConnection
HostConnectionPool,
HostConnectionPoolImpl,
HttpServerTerminated,
HttpTerminated,
OutgoingConnection
}
import pekko.http.scaladsl.model.HttpEntity.{ Chunk, ChunkStreamPart, Chunked, LastChunk }
import pekko.http.scaladsl.model.{ HttpEntity, _ }
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,10 @@ import org.apache.pekko
import pekko.http.impl.engine.client.OutgoingConnectionBlueprint.PrepareResponse
import pekko.http.impl.engine.parsing.ParserOutput
import pekko.http.impl.engine.parsing.ParserOutput.{
EntityChunk, EntityStreamError, StreamedEntityCreator, StrictEntityCreator
EntityChunk,
EntityStreamError,
StreamedEntityCreator,
StrictEntityCreator
}
import pekko.http.scaladsl.model._
import pekko.http.scaladsl.settings.ParserSettings
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,8 @@ import pekko.http.scaladsl.model.headers._
import pekko.http.impl.model.parser.CharacterClasses
import pekko.http.impl.util._
import pekko.http.scaladsl.settings.ParserSettings.{
IllegalResponseHeaderNameProcessingMode, IllegalResponseHeaderValueProcessingMode
IllegalResponseHeaderNameProcessingMode,
IllegalResponseHeaderValueProcessingMode
}
import pekko.testkit.EventFilter

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,10 @@ package org.apache.pekko.http.impl.engine.server
import org.apache.pekko
import pekko.http.impl.engine.parsing.ParserOutput
import pekko.http.impl.engine.parsing.ParserOutput.{
EntityChunk, EntityStreamError, StreamedEntityCreator, StrictEntityCreator
EntityChunk,
EntityStreamError,
StreamedEntityCreator,
StrictEntityCreator
}
import pekko.http.impl.engine.server.HttpServerBluePrint.PrepareRequests
import pekko.http.scaladsl.model._
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -479,8 +479,18 @@ class MockFailingWritePath extends java.nio.file.Path { selfPath =>
import java.nio.{ ByteBuffer, MappedByteBuffer }
import java.nio.channels.{ FileChannel, FileLock, ReadableByteChannel, SeekableByteChannel, WritableByteChannel }
import java.nio.file.{
AccessMode, CopyOption, DirectoryStream, FileStore, FileSystem, LinkOption, OpenOption, Path, PathMatcher,
WatchEvent, WatchKey, WatchService
AccessMode,
CopyOption,
DirectoryStream,
FileStore,
FileSystem,
LinkOption,
OpenOption,
Path,
PathMatcher,
WatchEvent,
WatchKey,
WatchService
}
import java.nio.file.attribute.{ BasicFileAttributes, FileAttribute, FileAttributeView, UserPrincipalLookupService }
import java.nio.file.spi.FileSystemProvider
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,10 @@ import pekko.http.scaladsl.model.StatusCodes
import pekko.http.scaladsl.model.headers.`Sec-WebSocket-Protocol`
import pekko.http.scaladsl.model.ws._
import pekko.http.scaladsl.server.{
ExpectedWebSocketRequestRejection, Route, RoutingSpec, UnsupportedWebSocketSubprotocolRejection
ExpectedWebSocketRequestRejection,
Route,
RoutingSpec,
UnsupportedWebSocketSubprotocolRejection
}
import pekko.http.scaladsl.testkit.WSProbe
import pekko.stream.OverflowStrategy
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,13 @@ import pekko.http.impl.model.JavaUri
import pekko.http.impl.util.JavaMapping
import pekko.http.impl.util.Util.convertIterable
import pekko.http.javadsl.model.{
HttpEntity, HttpHeader, HttpRequest, HttpResponse, RequestEntity, ResponseEntity, Uri
HttpEntity,
HttpHeader,
HttpRequest,
HttpResponse,
RequestEntity,
ResponseEntity,
Uri
}
import pekko.http.javadsl.server
import pekko.http.javadsl.server._
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,13 @@ import org.apache.pekko
import pekko.http.impl.model.JavaUri
import pekko.http.javadsl.marshalling.Marshaller
import pekko.http.javadsl.model.{
HttpHeader, HttpRequest, HttpResponse, RequestEntity, ResponseEntity, StatusCode, Uri
HttpHeader,
HttpRequest,
HttpResponse,
RequestEntity,
ResponseEntity,
StatusCode,
Uri
}
import pekko.http.javadsl.server.{ Rejection, Route, RoutingJavaMapping }
import pekko.http.javadsl.server.RoutingJavaMapping._
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -23,8 +23,19 @@ import pekko.http.impl.engine.ws.ByteStringSinkProbe
import pekko.http.impl.util.{ ExampleHttpContexts, PekkoSpecWithMaterializer }
import pekko.http.scaladsl.Http
import pekko.http.scaladsl.model.{
headers, AttributeKey, ContentTypes, HttpEntity, HttpHeader, HttpMethod, HttpMethods, HttpRequest, HttpResponse,
RequestResponseAssociation, StatusCode, StatusCodes, Uri
headers,
AttributeKey,
ContentTypes,
HttpEntity,
HttpHeader,
HttpMethod,
HttpMethods,
HttpRequest,
HttpResponse,
RequestResponseAssociation,
StatusCode,
StatusCodes,
Uri
}
import pekko.http.scaladsl.model.headers.HttpEncodings
import pekko.http.scaladsl.settings.ClientConnectionSettings
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,11 @@ import pekko.http.scaladsl.model.HttpEntity.Chunked
import pekko.http.scaladsl.model.HttpEntity.LastChunk
import pekko.http.scaladsl.model.HttpMethods.GET
import pekko.http.scaladsl.model.headers.{
`Access-Control-Allow-Origin`, `Cache-Control`, `Content-Length`, `Content-Type`, RawHeader
`Access-Control-Allow-Origin`,
`Cache-Control`,
`Content-Length`,
`Content-Type`,
RawHeader
}
import pekko.http.scaladsl.model.headers.CacheDirectives._
import pekko.http.scaladsl.settings.ClientConnectionSettings
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,12 @@ import java.nio.ByteOrder

import org.apache.pekko
import pekko.http.impl.engine.http2.FrameEvent.{
ContinuationFrame, HeadersFrame, PriorityFrame, Setting, SettingsFrame, WindowUpdateFrame
ContinuationFrame,
HeadersFrame,
PriorityFrame,
Setting,
SettingsFrame,
WindowUpdateFrame
}
import pekko.http.impl.engine.http2.Http2Protocol.{ ErrorCode, Flags, FrameType, SettingIdentifier }
import pekko.http.impl.engine.http2.framing.FrameRenderer
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -26,8 +26,20 @@ import pekko.http.impl.engine.ws.ByteStringSinkProbe
import pekko.http.impl.util.{ ExampleHttpContexts, PekkoSpecWithMaterializer }
import pekko.http.scaladsl.{ ClientTransport, Http }
import pekko.http.scaladsl.model.{
headers, AttributeKey, AttributeKeys, ContentTypes, HttpEntity, HttpHeader, HttpMethod, HttpMethods, HttpRequest,
HttpResponse, RequestResponseAssociation, StatusCode, StatusCodes, Uri
headers,
AttributeKey,
AttributeKeys,
ContentTypes,
HttpEntity,
HttpHeader,
HttpMethod,
HttpMethods,
HttpRequest,
HttpResponse,
RequestResponseAssociation,
StatusCode,
StatusCodes,
Uri
}
import pekko.http.scaladsl.model.headers.HttpEncodings
import pekko.http.scaladsl.settings.ClientConnectionSettings
Expand Down