diff -r 000000000000 -r 72b543305e3a email/imap4mtm/imapsession/test/src/cfakeinputstream.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/email/imap4mtm/imapsession/test/src/cfakeinputstream.cpp	Thu Dec 17 08:44:11 2009 +0200
@@ -0,0 +1,126 @@
+// Copyright (c) 2006-2009 Nokia Corporation and/or its subsidiary(-ies).
+// All rights reserved.
+// This component and the accompanying materials are made available
+// under the terms of "Eclipse Public License v1.0"
+// which accompanies this distribution, and is available
+// at the URL "http://www.eclipse.org/legal/epl-v10.html".
+//
+// Initial Contributors:
+// Nokia Corporation - initial contribution.
+//
+// Contributors:
+//
+// Description:
+//
+
+#include "cfakeinputstream.h"
+#include <utf.h>
+
+CFakeInputStream* CFakeInputStream::NewL(CTestExecuteLogger& aLogger)
+// static
+	{
+	return new(ELeave)CFakeInputStream(aLogger);
+	}
+
+CFakeInputStream::CFakeInputStream(CTestExecuteLogger& aLogger)
+	: CActive(CActive::EPriorityStandard)
+	, iLogger(aLogger)
+	{
+	CActiveScheduler::Add(this);
+	}
+		
+CFakeInputStream::~CFakeInputStream()
+	{
+	Cancel(); 
+	iInputStrings.Reset();
+	}
+
+void CFakeInputStream::Bind(MInputStreamObserver& aInputStreamObserver, TInt /*aLogId*/)
+	{
+	INFO_PRINTF1(_L("CFakeInputStream::Bind()"));
+	iInputStreamObserver = &aInputStreamObserver;
+	}
+void CFakeInputStream::ReadReq(TInt aIdleTime)
+	{
+	aIdleTime = aIdleTime;// To avoid build errors
+	INFO_PRINTF1(_L("CFakeInputStream::ReadReq()"));
+	iIsReading = ETrue;
+	CompleteSelf(KErrNone);
+	}
+void CFakeInputStream::CancelReadReq()
+	{
+	INFO_PRINTF1(_L("CFakeInputStream::CancelReadReq()"));
+	iIsReading = EFalse;
+	Cancel();
+	}
+TBool CFakeInputStream::IsReading()
+	{
+	INFO_PRINTF1(_L("CFakeInputStream::IsReading()"));
+	return iIsReading;
+	}
+	
+void CFakeInputStream::CompleteSelf(TInt aError)
+	{
+	TRequestStatus* status = &iStatus;
+	SetActive();
+	User::RequestComplete(status, aError);
+	}
+	
+void CFakeInputStream::RunL()
+	{
+	if (iNextInputString < iInputStrings.Count())
+		{
+		TPtrC8& ptrInputString = iInputStrings[iNextInputString];
+		
+		HBufC16* unicodeBuffer = NULL;
+		TRAPD(err,
+			unicodeBuffer = CnvUtfConverter::ConvertToUnicodeFromUtf8L(ptrInputString);
+		);
+		if (err == KErrNone)
+			{
+			INFO_PRINTF2(_L("S >>> C [%S]"), unicodeBuffer);
+			}
+		delete unicodeBuffer;
+		
+		iIsReading = EFalse;
+		iInputStreamObserver->ReceivedDataIndL(ptrInputString);
+		++iNextInputString;
+		}
+		
+	if (iNextInputString == iInputStrings.Count())
+		{
+		// No more data to deliver.
+		iInputStrings.Reset();
+		iNextInputString = 0;
+		
+		// Notify the observer if one has been set
+		if (iStreamIsEmptyObserver != NULL)
+			{
+			// Need to reset the observer before it is called.
+			MFakeInputStreamIsEmptyObserver* observer = iStreamIsEmptyObserver;
+			iStreamIsEmptyObserver = NULL;
+			
+			observer->OnInputStreamIsEmptyL();
+			}
+		}
+	}
+	
+void CFakeInputStream::DoCancel()
+	{}
+
+void CFakeInputStream::NotifyWhenStreamIsEmpty(MFakeInputStreamIsEmptyObserver& aStreamIsEmptyObserver)
+	{
+	ASSERT(iStreamIsEmptyObserver == NULL);	
+	iStreamIsEmptyObserver = &aStreamIsEmptyObserver;
+	}
+
+void CFakeInputStream::AppendInputStringL(const TDesC8& aString)
+	{
+	iInputStrings.AppendL(aString);
+	}
+
+void CFakeInputStream::ResetInputStrings()
+	{
+	iInputStrings.Reset();
+	iNextInputString = 0;
+	}