Package org.apache.pekko.http.impl.engine.ws

Class WebSocketClientSpec.TestSetup

java.lang.Object
org.apache.pekko.http.impl.engine.ws.WebSocketClientSpec.TestSetup
All Implemented Interfaces:
WSTestSetupBase, org.scalactic.Explicitly, org.scalactic.Tolerance, org.scalactic.TripleEquals, org.scalactic.TripleEqualsSupport, org.scalatest.Assertions, org.scalatest.matchers.dsl.MatcherWords, org.scalatest.matchers.should.Matchers, org.scalatest.verbs.ShouldVerb
Direct Known Subclasses:
WebSocketClientSpec.EstablishedConnectionSetup
Enclosing class:
WebSocketClientSpec
public abstract class WebSocketClientSpec.TestSetup extends Object implements WSTestSetupBase

  • Nested Class Summary

    Nested classes/interfaces inherited from interface org.scalatest.Assertions

    org.scalatest.Assertions.AssertionsHelper

    Nested classes/interfaces inherited from interface org.scalactic.Explicitly

    org.scalactic.Explicitly.DecidedByEquality<A extends Object>, org.scalactic.Explicitly.DecidedWord, org.scalactic.Explicitly.DeterminedByEquivalence<T extends Object>, org.scalactic.Explicitly.DeterminedWord, org.scalactic.Explicitly.TheAfterWord

    Nested classes/interfaces inherited from interface org.scalatest.matchers.should.Matchers

    org.scalatest.matchers.should.Matchers.AnWord, org.scalatest.matchers.should.Matchers.AnyShouldWrapper<T extends Object>, org.scalatest.matchers.should.Matchers.AWord, org.scalatest.matchers.should.Matchers.Collected, org.scalatest.matchers.should.Matchers.HavePropertyMatcherGenerator, org.scalatest.matchers.should.Matchers.KeyWord, org.scalatest.matchers.should.Matchers.RegexWord, org.scalatest.matchers.should.Matchers.RegexWrapper, org.scalatest.matchers.should.Matchers.ResultOfBeWordForAny<T extends Object>, org.scalatest.matchers.should.Matchers.ResultOfBeWordForCollectedAny<T extends Object>, org.scalatest.matchers.should.Matchers.ResultOfBeWordForCollectedArray<T extends Object>, org.scalatest.matchers.should.Matchers.ResultOfCollectedAny<T extends Object>, org.scalatest.matchers.should.Matchers.ResultOfContainWordForCollectedAny<T extends Object>, org.scalatest.matchers.should.Matchers.ResultOfEndWithWordForCollectedString, org.scalatest.matchers.should.Matchers.ResultOfEndWithWordForString, org.scalatest.matchers.should.Matchers.ResultOfFullyMatchWordForCollectedString, org.scalatest.matchers.should.Matchers.ResultOfFullyMatchWordForString, org.scalatest.matchers.should.Matchers.ResultOfHaveWordForCollectedExtent<A extends Object>, org.scalatest.matchers.should.Matchers.ResultOfHaveWordForExtent<A extends Object>, org.scalatest.matchers.should.Matchers.ResultOfIncludeWordForCollectedString, org.scalatest.matchers.should.Matchers.ResultOfIncludeWordForString, org.scalatest.matchers.should.Matchers.ResultOfNotWordForCollectedAny<T extends Object>, org.scalatest.matchers.should.Matchers.ResultOfStartWithWordForCollectedString, org.scalatest.matchers.should.Matchers.ResultOfStartWithWordForString, org.scalatest.matchers.should.Matchers.StringShouldWrapper, org.scalatest.matchers.should.Matchers.TheSameInstanceAsPhrase, org.scalatest.matchers.should.Matchers.ValueWord

    Nested classes/interfaces inherited from interface org.scalatest.verbs.ShouldVerb

    org.scalatest.verbs.ShouldVerb.StringShouldWrapperForVerb

    Nested classes/interfaces inherited from interface org.scalactic.Tolerance

    org.scalactic.Tolerance.PlusOrMinusWrapper<T extends Object>

    Nested classes/interfaces inherited from interface org.scalactic.TripleEqualsSupport

    org.scalactic.TripleEqualsSupport.AToBEquivalenceConstraint<A extends Object,B extends Object>, org.scalactic.TripleEqualsSupport.BToAEquivalenceConstraint<A extends Object,B extends Object>, org.scalactic.TripleEqualsSupport.CheckingEqualizer<L extends Object>, org.scalactic.TripleEqualsSupport.EqualityConstraint<A extends Object,B extends Object>, org.scalactic.TripleEqualsSupport.Equalizer<L extends Object>, org.scalactic.TripleEqualsSupport.Spread<T extends Object>, org.scalactic.TripleEqualsSupport.Spread$, org.scalactic.TripleEqualsSupport.TripleEqualsInvocation<T extends Object>, org.scalactic.TripleEqualsSupport.TripleEqualsInvocation$, org.scalactic.TripleEqualsSupport.TripleEqualsInvocationOnSpread<T extends Object>, org.scalactic.TripleEqualsSupport.TripleEqualsInvocationOnSpread$

  • Constructor Summary

    Constructors
    Constructor
    Description
    TestSetup()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.scalatest.matchers.should.Matchers.AWord
    a()
     
    org.scalactic.Explicitly.TheAfterWord
    after()
     
    org.scalatest.matchers.should.Matchers.AnWord
    an()
     
    org.scalatest.matchers.dsl.BeWord
    be()
     
    protected abstract org.apache.pekko.stream.scaladsl.Flow<Message,Message,org.apache.pekko.NotUsed>
    clientImplementation()
     
    org.apache.pekko.stream.scaladsl.BidiFlow<Message,org.apache.pekko.stream.TLSProtocol.SslTlsOutbound,org.apache.pekko.stream.TLSProtocol.SslTlsInbound,Message,scala.concurrent.Future<WebSocketUpgradeResponse>>
    clientLayer()
     
    void
    closeNetworkInput()
     
    org.scalatest.verbs.CompileWord
    compile()
     
    org.scalatest.matchers.dsl.ContainWord
    contain()
     
    org.scalactic.Explicitly.DecidedWord
    decided()
     
    org.scalatest.matchers.dsl.DefinedWord
    defined()
     
    org.scalactic.Explicitly.DeterminedWord
    determined()
     
    org.scalatest.matchers.dsl.EmptyWord
    empty()
     
    org.scalatest.matchers.dsl.EndWithWord
    endWith()
     
    org.scalatest.matchers.dsl.ExistWord
    exist()
     
    org.apache.pekko.util.ByteString
    expectBytes(int length)
     
    void
    expectBytes(org.apache.pekko.util.ByteString bytes)
     
    InvalidUpgradeResponse
    expectInvalidUpgradeResponse()
     
    void
    expectInvalidUpgradeResponseCause(String expected)
     
    void
    expectNetworkAbort()
     
    void
    expectNetworkClose()
     
    void
    expectNoWireData()
     
    void
    expectResponse(WebSocketUpgradeResponse response)
     
    void
    expectWireData(String s)
     
    void
    expectWireData(org.apache.pekko.util.ByteString bs)
     
    org.scalatest.matchers.dsl.FullyMatchWord
    fullyMatch()
     
    org.scalatest.matchers.dsl.HaveWord
    have()
     
    org.scalatest.matchers.dsl.IncludeWord
    include()
     
    org.scalatest.matchers.should.Matchers.KeyWord
    key()
     
    org.scalatest.matchers.dsl.LengthWord
    length()
     
    org.scalatest.matchers.dsl.MatchPatternWord
    matchPattern()
     
    org.apache.pekko.stream.testkit.TestPublisher.Probe<org.apache.pekko.util.ByteString>
    netIn()
     
    ByteStringSinkProbe
    netOut()
     
    protected scala.concurrent.duration.FiniteDuration
    noMsgTimeout()
     
    org.scalatest.matchers.dsl.NotWord
    not()
     
    Random
    random()
     
    org.scalatest.matchers.dsl.ReadableWord
    readable()
     
    org.scalatest.matchers.should.Matchers.RegexWord
    regex()
     
    protected scala.Option<String>
    requestedSubProtocol()
     
    scala.concurrent.Future<WebSocketUpgradeResponse>
    response()
     
    void
    send(org.apache.pekko.util.ByteString bytes)
     
    void
    sendWireData(String data)
     
    void
    sendWireData(org.apache.pekko.util.ByteString data)
     
    ClientConnectionSettings
    settings()
     
    org.scalatest.matchers.dsl.SizeWord
    size()
     
    org.scalatest.matchers.dsl.SortedWord
    sorted()
     
    org.scalatest.matchers.dsl.StartWithWord
    startWith()
     
    final org.scalatest.compatible.Assertion
    succeed()
     
    Uri
    targetUri()
     
    org.scalatest.matchers.should.Matchers.TheSameInstanceAsPhrase
    theSameInstanceAs()
     
    org.scalatest.verbs.TypeCheckWord
    typeCheck()
     
    org.scalatest.matchers.should.Matchers.ValueWord
    value()
     
    String
    wipeDate(String string)
     
    org.scalatest.matchers.dsl.WritableWord
    writable()
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface org.scalatest.Assertions

    assertResult, assertResult, assertThrows, cancel, cancel, cancel, cancel, fail, fail, fail, fail, intercept, newAssertionFailedException, newTestCanceledException, org$scalatest$Assertions$_setter_$succeed_$eq, pending, pendingUntilFixed, withClue

    Methods inherited from interface org.scalactic.Explicitly

    org$scalactic$Explicitly$_setter_$after_$eq, org$scalactic$Explicitly$_setter_$decided_$eq, org$scalactic$Explicitly$_setter_$determined_$eq

    Methods inherited from interface org.scalatest.matchers.should.Matchers

    $greater, $greater$eq, $less, $less$eq, a, all, all, all, all, allElementsOf, allOf, an, atLeast, atLeast, atLeast, atLeast, atLeastOneElementOf, atLeastOneOf, atMost, atMost, atMost, atMost, atMostOneElementOf, atMostOneOf, between, between, between, convertSymbolToHavePropertyMatcherGenerator, convertToAnyShouldWrapper, convertToRegexWrapper, convertToStringShouldWrapper, definedAt, doCollected, equal, equal, every, every, every, every, exactly, exactly, exactly, exactly, inOrder, inOrderElementsOf, inOrderOnly, message, no, no, no, noElementsOf, noneOf, of, oneElementOf, oneOf, only, org$scalatest$matchers$should$Matchers$_setter_$a_$eq, org$scalatest$matchers$should$Matchers$_setter_$an_$eq, org$scalatest$matchers$should$Matchers$_setter_$key_$eq, org$scalatest$matchers$should$Matchers$_setter_$org$scalatest$matchers$should$Matchers$$AllCollected_$eq, org$scalatest$matchers$should$Matchers$_setter_$org$scalatest$matchers$should$Matchers$$EveryCollected_$eq, org$scalatest$matchers$should$Matchers$_setter_$org$scalatest$matchers$should$Matchers$$NoCollected_$eq, org$scalatest$matchers$should$Matchers$_setter_$org$scalatest$matchers$should$Matchers$$ShouldMethodHelper_$eq, org$scalatest$matchers$should$Matchers$_setter_$regex_$eq, org$scalatest$matchers$should$Matchers$_setter_$theSameInstanceAs_$eq, org$scalatest$matchers$should$Matchers$_setter_$value_$eq, org$scalatest$matchers$should$Matchers$$AllCollected, org$scalatest$matchers$should$Matchers$$AtLeastCollected, org$scalatest$matchers$should$Matchers$$AtMostCollected, org$scalatest$matchers$should$Matchers$$BetweenCollected, org$scalatest$matchers$should$Matchers$$EveryCollected, org$scalatest$matchers$should$Matchers$$ExactlyCollected, org$scalatest$matchers$should$Matchers$$NoCollected, org$scalatest$matchers$should$Matchers$$ShouldMethodHelper, the, theSameElementsAs, theSameElementsInOrderAs, thrownBy

    Methods inherited from interface org.scalatest.matchers.dsl.MatcherWords

    equal, noException, org$scalatest$matchers$dsl$MatcherWords$_setter_$be_$eq, org$scalatest$matchers$dsl$MatcherWords$_setter_$compile_$eq, org$scalatest$matchers$dsl$MatcherWords$_setter_$contain_$eq, org$scalatest$matchers$dsl$MatcherWords$_setter_$defined_$eq, org$scalatest$matchers$dsl$MatcherWords$_setter_$empty_$eq, org$scalatest$matchers$dsl$MatcherWords$_setter_$endWith_$eq, org$scalatest$matchers$dsl$MatcherWords$_setter_$exist_$eq, org$scalatest$matchers$dsl$MatcherWords$_setter_$fullyMatch_$eq, org$scalatest$matchers$dsl$MatcherWords$_setter_$have_$eq, org$scalatest$matchers$dsl$MatcherWords$_setter_$include_$eq, org$scalatest$matchers$dsl$MatcherWords$_setter_$length_$eq, org$scalatest$matchers$dsl$MatcherWords$_setter_$matchPattern_$eq, org$scalatest$matchers$dsl$MatcherWords$_setter_$not_$eq, org$scalatest$matchers$dsl$MatcherWords$_setter_$readable_$eq, org$scalatest$matchers$dsl$MatcherWords$_setter_$size_$eq, org$scalatest$matchers$dsl$MatcherWords$_setter_$sorted_$eq, org$scalatest$matchers$dsl$MatcherWords$_setter_$startWith_$eq, org$scalatest$matchers$dsl$MatcherWords$_setter_$typeCheck_$eq, org$scalatest$matchers$dsl$MatcherWords$_setter_$writable_$eq

    Methods inherited from interface org.scalatest.verbs.ShouldVerb

    convertToStringShouldWrapperForVerb

    Methods inherited from interface org.scalactic.Tolerance

    convertNumericToPlusOrMinusWrapper

    Methods inherited from interface org.scalactic.TripleEquals

    conversionCheckedConstraint, convertEquivalenceToAToBConstraint, convertEquivalenceToAToBConversionConstraint, convertEquivalenceToBToAConstraint, convertEquivalenceToBToAConversionConstraint, convertToCheckingEqualizer, convertToEqualizer, lowPriorityConversionCheckedConstraint, lowPriorityTypeCheckedConstraint, typeCheckedConstraint, unconstrainedEquality

    Methods inherited from interface org.scalactic.TripleEqualsSupport

    $bang$eq$eq, $bang$eq$eq, $bang$eq$eq, $eq$eq$eq, $eq$eq$eq, $eq$eq$eq, defaultEquality

    Methods inherited from interface org.apache.pekko.http.impl.engine.ws.WSTestSetupBase

    expectFrameHeaderOnNetwork, expectFrameHeaderOnNetwork, expectFrameOnNetwork, expectMaskedCloseFrame, expectMaskedFrameOnNetwork, expectNetworkData, expectNetworkData, expectWSCloseFrame, expectWSFrame, sendWSCloseFrame, sendWSFrame

  • Constructor Details

    • TestSetup

      public TestSetup()

  • Method Details

    • a

      public org.scalatest.matchers.should.Matchers.AWord a()
      Specified by:
      a in interface org.scalatest.matchers.should.Matchers

    • after

      public org.scalactic.Explicitly.TheAfterWord after()
      Specified by:
      after in interface org.scalactic.Explicitly

    • an

      public org.scalatest.matchers.should.Matchers.AnWord an()
      Specified by:
      an in interface org.scalatest.matchers.should.Matchers

    • be

      public org.scalatest.matchers.dsl.BeWord be()
      Specified by:
      be in interface org.scalatest.matchers.dsl.MatcherWords

    • clientImplementation

      protected abstract org.apache.pekko.stream.scaladsl.Flow<Message,Message,org.apache.pekko.NotUsed> clientImplementation()

    • clientLayer

      public org.apache.pekko.stream.scaladsl.BidiFlow<Message,org.apache.pekko.stream.TLSProtocol.SslTlsOutbound,org.apache.pekko.stream.TLSProtocol.SslTlsInbound,Message,scala.concurrent.Future<WebSocketUpgradeResponse>> clientLayer()

    • closeNetworkInput

      public void closeNetworkInput()

    • compile

      public org.scalatest.verbs.CompileWord compile()
      Specified by:
      compile in interface org.scalatest.matchers.dsl.MatcherWords

    • contain

      public org.scalatest.matchers.dsl.ContainWord contain()
      Specified by:
      contain in interface org.scalatest.matchers.dsl.MatcherWords

    • decided

      public org.scalactic.Explicitly.DecidedWord decided()
      Specified by:
      decided in interface org.scalactic.Explicitly

    • defined

      public org.scalatest.matchers.dsl.DefinedWord defined()
      Specified by:
      defined in interface org.scalatest.matchers.dsl.MatcherWords

    • determined

      public org.scalactic.Explicitly.DeterminedWord determined()
      Specified by:
      determined in interface org.scalactic.Explicitly

    • empty

      public org.scalatest.matchers.dsl.EmptyWord empty()
      Specified by:
      empty in interface org.scalatest.matchers.dsl.MatcherWords

    • endWith

      public org.scalatest.matchers.dsl.EndWithWord endWith()
      Specified by:
      endWith in interface org.scalatest.matchers.dsl.MatcherWords

    • exist

      public org.scalatest.matchers.dsl.ExistWord exist()
      Specified by:
      exist in interface org.scalatest.matchers.dsl.MatcherWords

    • expectBytes

      public org.apache.pekko.util.ByteString expectBytes(int length)
      Specified by:
      expectBytes in interface WSTestSetupBase

    • expectBytes

      public void expectBytes(org.apache.pekko.util.ByteString bytes)
      Specified by:
      expectBytes in interface WSTestSetupBase

    • expectInvalidUpgradeResponse

      public InvalidUpgradeResponse expectInvalidUpgradeResponse()

    • expectInvalidUpgradeResponseCause

      public void expectInvalidUpgradeResponseCause(String expected)

    • expectNetworkAbort

      public void expectNetworkAbort()

    • expectNetworkClose

      public void expectNetworkClose()

    • expectNoWireData

      public void expectNoWireData()

    • expectResponse

      public void expectResponse(WebSocketUpgradeResponse response)

    • expectWireData

      public void expectWireData(String s)

    • expectWireData

      public void expectWireData(org.apache.pekko.util.ByteString bs)

    • fullyMatch

      public org.scalatest.matchers.dsl.FullyMatchWord fullyMatch()
      Specified by:
      fullyMatch in interface org.scalatest.matchers.dsl.MatcherWords

    • have

      public org.scalatest.matchers.dsl.HaveWord have()
      Specified by:
      have in interface org.scalatest.matchers.dsl.MatcherWords

    • include

      public org.scalatest.matchers.dsl.IncludeWord include()
      Specified by:
      include in interface org.scalatest.matchers.dsl.MatcherWords

    • key

      public org.scalatest.matchers.should.Matchers.KeyWord key()
      Specified by:
      key in interface org.scalatest.matchers.should.Matchers

    • length

      public org.scalatest.matchers.dsl.LengthWord length()
      Specified by:
      length in interface org.scalatest.matchers.dsl.MatcherWords

    • matchPattern

      public org.scalatest.matchers.dsl.MatchPatternWord matchPattern()
      Specified by:
      matchPattern in interface org.scalatest.matchers.dsl.MatcherWords

    • netIn

      public org.apache.pekko.stream.testkit.TestPublisher.Probe<org.apache.pekko.util.ByteString> netIn()

    • netOut

      public ByteStringSinkProbe netOut()

    • noMsgTimeout

      protected scala.concurrent.duration.FiniteDuration noMsgTimeout()

    • not

      public org.scalatest.matchers.dsl.NotWord not()
      Specified by:
      not in interface org.scalatest.matchers.dsl.MatcherWords

    • random

      public Random random()

    • readable

      public org.scalatest.matchers.dsl.ReadableWord readable()
      Specified by:
      readable in interface org.scalatest.matchers.dsl.MatcherWords

    • regex

      public org.scalatest.matchers.should.Matchers.RegexWord regex()
      Specified by:
      regex in interface org.scalatest.matchers.should.Matchers

    • requestedSubProtocol

      protected scala.Option<String> requestedSubProtocol()

    • response

      public scala.concurrent.Future<WebSocketUpgradeResponse> response()

    • send

      public void send(org.apache.pekko.util.ByteString bytes)
      Specified by:
      send in interface WSTestSetupBase

    • sendWireData

      public void sendWireData(String data)

    • sendWireData

      public void sendWireData(org.apache.pekko.util.ByteString data)

    • settings

      public ClientConnectionSettings settings()

    • size

      public org.scalatest.matchers.dsl.SizeWord size()
      Specified by:
      size in interface org.scalatest.matchers.dsl.MatcherWords

    • sorted

      public org.scalatest.matchers.dsl.SortedWord sorted()
      Specified by:
      sorted in interface org.scalatest.matchers.dsl.MatcherWords

    • startWith

      public org.scalatest.matchers.dsl.StartWithWord startWith()
      Specified by:
      startWith in interface org.scalatest.matchers.dsl.MatcherWords

    • succeed

      public final org.scalatest.compatible.Assertion succeed()
      Specified by:
      succeed in interface org.scalatest.Assertions

    • targetUri

      public Uri targetUri()

    • theSameInstanceAs

      public org.scalatest.matchers.should.Matchers.TheSameInstanceAsPhrase theSameInstanceAs()
      Specified by:
      theSameInstanceAs in interface org.scalatest.matchers.should.Matchers

    • typeCheck

      public org.scalatest.verbs.TypeCheckWord typeCheck()
      Specified by:
      typeCheck in interface org.scalatest.matchers.dsl.MatcherWords

    • value

      public org.scalatest.matchers.should.Matchers.ValueWord value()
      Specified by:
      value in interface org.scalatest.matchers.should.Matchers

    • wipeDate

      public String wipeDate(String string)

    • writable

      public org.scalatest.matchers.dsl.WritableWord writable()
      Specified by:
      writable in interface org.scalatest.matchers.dsl.MatcherWords