Skip to content

Commit

Permalink
fixup! Closes finagle#75 - change PostgresClientImpl to not cache fai…
Browse files Browse the repository at this point in the history
…lures
  • Loading branch information
leonmaia committed Nov 13, 2018
1 parent 27f45fd commit b447e45
Showing 1 changed file with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -83,13 +83,13 @@ class PostgresClientImpl(
}

// The OIDs to be used when sending parameters
private[postgres] val encodeOids = Refresh.every(1.hour) {
private[postgres] val encodeOids =
typeMap().map {
tm => tm.toIndexedSeq.map {
case (oid, PostgresClient.TypeSpecifier(receiveFn, typeName, elemOid)) => typeName -> oid
}.groupBy(_._1).mapValues(_.map(_._2).min)
tm =>
tm.toIndexedSeq.map {
case (oid, PostgresClient.TypeSpecifier(receiveFn, typeName, elemOid)) => typeName -> oid
}.groupBy(_._1).mapValues(_.map(_._2).min)
}
}

/*
* Execute some actions inside of a transaction using a single connection
Expand Down

0 comments on commit b447e45

Please sign in to comment.