ReadTranslatedQueryDefinitionAggregator.scala
dae66ba237b4master

ReadTranslatedQueryDefinitionAggregator.scala
View Options

			package net.shrine.aggregation

			import net.shrine.aggregation.BasicAggregator.Valid
			import net.shrine.protocol.SingleNodeReadTranslatedQueryDefinitionResponse
			import net.shrine.protocol.QueryResult
			import net.shrine.protocol.ShrineResponse
			import net.shrine.protocol.AggregatedReadTranslatedQueryDefinitionResponse
			import net.shrine.protocol.ErrorResponse
			import net.shrine.protocol.BaseShrineResponse

			/**
			* @author clint
			* @since Feb 14, 2014
			*/
			final class ReadTranslatedQueryDefinitionAggregator extends IgnoresErrorsAggregator[SingleNodeReadTranslatedQueryDefinitionResponse] {
			override private[aggregation] def makeResponseFrom(validResponses: Iterable[Valid[SingleNodeReadTranslatedQueryDefinitionResponse]]): BaseShrineResponse = {
			if(validResponses.isEmpty) { ErrorResponse(NoValidResponsesToAggregate()) }
			else {
			val singleNodeResults = validResponses.map(_.response.result).toSeq

			AggregatedReadTranslatedQueryDefinitionResponse(singleNodeResults)
			}
			}
			}