Skip to content
This repository

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
  • 3 commits
  • 15 files changed
  • 0 comments
  • 1 contributor
2  core/src/main/scala/execution.scala
... ... @@ -1,4 +1,4 @@
1   -package com.patch.dispatch
  1 +package dispatch_reboot
2 2
3 3 import com.ning.http.client.{
4 4 AsyncHttpClient, RequestBuilder, Request, Response, AsyncHandler
2  core/src/main/scala/handlers.scala
... ... @@ -1,4 +1,4 @@
1   -package com.patch.dispatch
  1 +package dispatch_reboot
2 2
3 3 import com.ning.http.client
4 4 import client.{
4 core/src/main/scala/oauth/exchange.scala
... ... @@ -1,6 +1,6 @@
1   -package com.patch.dispatch.oauth
  1 +package dispatch_reboot.oauth
2 2
3   -import com.patch.dispatch._
  3 +import dispatch_reboot._
4 4
5 5 import com.ning.http.client.oauth._
6 6
7 core/src/main/scala/oauth/handlers.scala
... ... @@ -1,6 +1,7 @@
1   -package com.patch.dispatch.oauth
  1 +package dispatch_reboot.oauth
  2 +
  3 +import dispatch_reboot._
2 4
3   -import com.patch.dispatch._
4 5 import com.ning.http.client.oauth._
5 6
6 7 object AsOAuth {
@@ -21,5 +22,5 @@ object AsOAuth {
21 22 "No token found in response: \n\n" + str
22 23 }
23 24 }
24   - val token = As.string.andThen(tokenDecode)
  25 + val token = dispatch_reboot.As.string.andThen(tokenDecode)
25 26 }
2  core/src/main/scala/oauth/package.scala
... ... @@ -1,4 +1,4 @@
1   -package com.patch.dispatch
  1 +package dispatch_reboot
2 2
3 3 package object oauth {
4 4 implicit def implySigningVerbs(builder: Req) =
4 core/src/main/scala/oauth/requests.scala
... ... @@ -1,8 +1,8 @@
1   -package com.patch.dispatch.oauth
  1 +package dispatch_reboot.oauth
2 2
3 3 import com.ning.http.client.oauth._
4 4
5   -import com.patch.dispatch._
  5 +import dispatch_reboot._
6 6
7 7 class SigningVerbs(val subject: Req) extends RequestVerbs {
8 8 val emptyToken = new RequestToken("", "")
4 core/src/main/scala/package.scala
... ... @@ -1,6 +1,4 @@
1   -package com.patch
2   -
3   -package object dispatch {
  1 +package object dispatch_reboot {
4 2 /** Type alias for RequestBuilder, our typical request definitions */
5 3 type Req = com.ning.http.client.RequestBuilder
6 4
2  core/src/main/scala/projections.scala
... ... @@ -1,4 +1,4 @@
1   -package com.patch.dispatch
  1 +package dispatch_reboot
2 2
3 3 // handy projections
4 4
4 core/src/main/scala/promise.scala
... ... @@ -1,4 +1,4 @@
1   -package com.patch.dispatch
  1 +package dispatch_reboot
2 2
3 3 import com.ning.http.client.ListenableFuture
4 4 import java.util.{concurrent => juc}
@@ -15,7 +15,7 @@ trait Promise[+A] extends PromiseSIP[A] { self =>
15 15 protected lazy val result = allCatch.either { claim }
16 16
17 17 /** Listener to be called in an executor when promise is available */
18   - protected [dispatch] def addListener(f: () => Unit)
  18 + protected [dispatch_reboot] def addListener(f: () => Unit)
19 19
20 20 // lazily assign result when available, e.g. to evaluate mapped function
21 21 // that may kick off further promises
2  core/src/main/scala/requests.scala
... ... @@ -1,4 +1,4 @@
1   -package com.patch.dispatch
  1 +package dispatch_reboot
2 2
3 3 import com.ning.http.client.RequestBuilder
4 4
4 core/src/test/scala/basic.scala
... ... @@ -1,4 +1,4 @@
1   -package com.patch.dispatch.spec
  1 +package dispatch_reboot.spec
2 2
3 3 import org.scalacheck._
4 4
@@ -18,7 +18,7 @@ with unfiltered.spec.ServerCleanup {
18 18 }).start()
19 19 }
20 20
21   - import dispatch._
  21 + import dispatch_reboot._
22 22
23 23 def localhost = host("127.0.0.1", server.port)
24 24
4 core/src/test/scala/compose.scala
... ... @@ -1,4 +1,4 @@
1   -package com.patch.dispatch.spec
  1 +package dispatch_reboot.spec
2 2
3 3 import org.scalacheck._
4 4
@@ -21,7 +21,7 @@ with unfiltered.spec.ServerCleanup {
21 21 }).start()
22 22 }
23 23
24   - import dispatch._
  24 + import dispatch_reboot._
25 25
26 26 def localhost = host("127.0.0.1", server.port)
27 27
4 core/src/test/scala/fail.scala
... ... @@ -1,4 +1,4 @@
1   -package com.patch.dispatch.spec
  1 +package dispatch_reboot.spec
2 2
3 3 import org.scalacheck._
4 4
@@ -18,7 +18,7 @@ with unfiltered.spec.ServerCleanup {
18 18 }).start()
19 19 }
20 20
21   - import dispatch._
  21 + import dispatch_reboot._
22 22
23 23 def localhost = host("127.0.0.1", server.port)
24 24
4 core/src/test/scala/iterable.scala
... ... @@ -1,4 +1,4 @@
1   -package com.patch.dispatch.spec
  1 +package dispatch_reboot.spec
2 2
3 3 import org.scalacheck._
4 4
@@ -23,7 +23,7 @@ with unfiltered.spec.ServerCleanup {
23 23 }).start()
24 24 }
25 25
26   - import dispatch._
  26 + import dispatch_reboot._
27 27
28 28 def localhost = host("127.0.0.1", server.port)
29 29
4 core/src/test/scala/server.scala
... ... @@ -1,4 +1,4 @@
1   -package com.patch.dispatch.spec
  1 +package dispatch_reboot.spec
2 2
3 3 import org.scalacheck._
4 4
@@ -7,7 +7,7 @@ extends Properties("Server")
7 7 with unfiltered.spec.ServerCleanup {
8 8 import Prop._
9 9
10   - import dispatch._
  10 + import dispatch_reboot._
11 11
12 12 val server = {
13 13 import unfiltered.netty

No commit comments for this range

Something went wrong with that request. Please try again.