diff options
| author | John St John <johnthesaintjohn@gmail.com> | 2017-09-27 11:50:17 -0700 |
|---|---|---|
| committer | John St John <johnthesaintjohn@gmail.com> | 2017-09-27 11:50:17 -0700 |
| commit | 80b4c45ce4e6b35dfb3455a200082d7589c9f72d (patch) | |
| tree | 4d014b0e97790fe006cab5a39ec0db2178f469f8 | |
| parent | f384bfcf0870c3881a3a4c6afb6eca9baf163077 (diff) | |
| download | driver-core-80b4c45ce4e6b35dfb3455a200082d7589c9f72d.tar.gz driver-core-80b4c45ce4e6b35dfb3455a200082d7589c9f72d.tar.bz2 driver-core-80b4c45ce4e6b35dfb3455a200082d7589c9f72d.zip | |
2_11 does not support .fold on Trys
| -rw-r--r-- | src/main/scala/xyz/driver/core/trace/ExceptionLoggingSizedBufferingTraceConsumer.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/main/scala/xyz/driver/core/trace/ExceptionLoggingSizedBufferingTraceConsumer.scala b/src/main/scala/xyz/driver/core/trace/ExceptionLoggingSizedBufferingTraceConsumer.scala index 64ae15a..fd3a843 100644 --- a/src/main/scala/xyz/driver/core/trace/ExceptionLoggingSizedBufferingTraceConsumer.scala +++ b/src/main/scala/xyz/driver/core/trace/ExceptionLoggingSizedBufferingTraceConsumer.scala @@ -19,8 +19,8 @@ class ExceptionLoggingFlushableTraceConsumer(traceConsumer: FlushableTraceConsum log.error(s"Encountered exception logging to google $exception") override def receive(trace: Traces): Unit = - Try(flushableTraceConsumer.receive(trace)).fold(exceptionLogger, identity) + Try(flushableTraceConsumer.receive(trace)).recover({case e => exceptionLogger(e)}).get override def flush(): Unit = - Try(flushableTraceConsumer.flush()).fold(exceptionLogger, identity) + Try(flushableTraceConsumer.flush()).recover({case e => exceptionLogger(e)}).get } |